diff --git a/turbinia/task_manager.py b/turbinia/task_manager.py index 8e978e0d1..b01a60f5d 100644 --- a/turbinia/task_manager.py +++ b/turbinia/task_manager.py @@ -697,7 +697,6 @@ def process_tasks(self): log.warning(message) task = self.timeout_task(task, config.CELERY_EXPIRATION_TIME) task.result.status = message - task.result.close(self, success=False, status=message) completed_tasks.append(task) else: check_timeout = True