From f5d5afcb62b95476ab86b46f21afac5b1604560b Mon Sep 17 00:00:00 2001 From: David Graham Date: Mon, 20 Nov 2023 10:22:38 -0500 Subject: [PATCH] remove signal that was causing problems --- server/apps/core/tasks.py | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/server/apps/core/tasks.py b/server/apps/core/tasks.py index 19eb76db2..d0c63f276 100644 --- a/server/apps/core/tasks.py +++ b/server/apps/core/tasks.py @@ -2,22 +2,11 @@ import time from celery import Task, shared_task -from celery.signals import task_prerun from django.core.cache import cache logger = logging.getLogger(__name__) -@task_prerun.connect -def cache_status_as_received(sender, task_id, task, args, kwargs, **kw): - cached_state = cache.get(task_id) - if cached_state is None: - cache.set( - task_id, - {"status": "Received", "taskName": task.name, "taskId": task_id}, - ) - - @shared_task(bind=True, name="example task") def example_task(self: Task): cache.set(