diff --git a/app/tasks.py b/app/tasks.py index 6ffd39e..131e92d 100644 --- a/app/tasks.py +++ b/app/tasks.py @@ -619,7 +619,7 @@ class TaskManager: raise ValueError(f"Task {task_name} is not defined.") task = globals()[task_name].delay(*args, **kwargs) self.tasks[task_name] = task.id - return task.id + return task.id,'STARTED' def get_task_status(self, task_name): if task_name not in self.tasks: