sartography/cr-connect-workflow
1
0
Fork 0
mirror of https://github.com/sartography/cr-connect-workflow.git synced 2025-02-23 21:28:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

#557 - scheduler recursion because each call to 'process_witing_tasks' would kick off an additional scheduler by settting up a new app_context.

Browse Source
This commit is contained in:
Dan 2021-12-09 08:54:44 -05:00
parent 412290f2ab
commit 06960644fa
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
crc/__init__.py
View File

@ -56,15 +56,18 @@ from crc.services.file_service import FileService
from crc.services.workflow_service import WorkflowService from crc.services.workflow_service import WorkflowService
connexion_app.add_api('api.yml', base_path='/v1.0') connexion_app.add_api('api.yml', base_path='/v1.0')
# needed function to avoid circular import
# needed function to avoid circular import
def process_waiting_tasks(): def process_waiting_tasks():
with app.app_context(): with app.app_context():
WorkflowService.do_waiting() WorkflowService.do_waiting()
scheduler.add_job(process_waiting_tasks,'interval',minutes=1)
scheduler.add_job(FileService.cleanup_file_data, 'interval', minutes=1440) # once a day @app.before_first_request
scheduler.start() def init_scheduler():
scheduler.add_job(process_waiting_tasks, 'interval', minutes=1)
scheduler.add_job(FileService.cleanup_file_data, 'interval', minutes=1440) # once a day
scheduler.start()
# Convert list of allowed origins to list of regexes # Convert list of allowed origins to list of regexes