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(