From 2d39957070efe77b4b7f1bd654562b85e2953825 Mon Sep 17 00:00:00 2001 From: Jean-Marie Favreau Date: Sat, 1 Mar 2025 15:25:54 +0100 Subject: [PATCH] =?UTF-8?q?On=20am=C3=A9liore=20le=20red=C3=A9marrage=20de?= =?UTF-8?q?=20Celery?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Fix #325 --- src/agenda_culturel/celery.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/agenda_culturel/celery.py b/src/agenda_culturel/celery.py index b95d6c3..acc1bb6 100644 --- a/src/agenda_culturel/celery.py +++ b/src/agenda_culturel/celery.py @@ -297,6 +297,8 @@ def screenshot(self): @worker_ready.connect def at_start(sender, **k): + logger.info("Worker is ready") + # create screenshot if not os.path.isfile(SCREENSHOT_FILE): logger.info("Init screenshot file") with sender.app.connection() as conn: @@ -304,6 +306,12 @@ def at_start(sender, **k): else: 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) def run_all_recurrent_imports(self, only_fb=False):