setop/agenda_culturel
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

On améliore le redémarrage de Celery

Browse Source 
Fix #325
This commit is contained in:
Jean-Marie Favreau 2025-03-01 15:25:54 +01:00
parent f9a72a4115
commit 2d39957070
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/agenda_culturel/celery.py
View File

@ -297,6 +297,8 @@ def screenshot(self):
@worker_ready.connect @worker_ready.connect
def at_start(sender, **k): def at_start(sender, **k):
logger.info("Worker is ready")
# create screenshot
if not os.path.isfile(SCREENSHOT_FILE): if not os.path.isfile(SCREENSHOT_FILE):
logger.info("Init screenshot file") logger.info("Init screenshot file")
with sender.app.connection() as conn: with sender.app.connection() as conn:
@ -304,6 +306,12 @@ def at_start(sender, **k):
else: else:
logger.info("Screenshot file already exists") logger.info("Screenshot file already exists")
# cancel running tasks
from agenda_culturel.models import BatchImportation
logger.info("Cancel running importation tasks")
running_tasks = BatchImportation.objects.filter(status=BatchImportation.STATUS.RUNNING).update(status=BatchImportation.STATUS.CANCELED)
@app.task(bind=True) @app.task(bind=True)
def run_all_recurrent_imports(self, only_fb=False): def run_all_recurrent_imports(self, only_fb=False):