diff --git a/dvc/repo/experiments/queue/celery.py b/dvc/repo/experiments/queue/celery.py index 07598b2a6..e85b1cf14 100644 --- a/dvc/repo/experiments/queue/celery.py +++ b/dvc/repo/experiments/queue/celery.py @@ -337,9 +337,7 @@ class LocalCeleryQueue(BaseStashQueue): remained_entries[entry], ) backend = self.celery.backend - backend.mark_as_failure( # type: ignore[attr-defined] - task_id, None - ) + backend.mark_as_failure(task_id, None) # type: ignore[attr-defined] if remained_revs: raise CannotKillTasksError(remained_revs)