Fix bad "code cleanup" in celery executor (#34192)

Fixes error introduced in code cleanup PR #33987
apache · Sep 8, 2023 · 50cccbd · 50cccbd
1 parent a09a823
commit 50cccbd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/providers/celery/executors/celery_executor.py b/airflow/providers/celery/executors/celery_executor.py
@@ -368,7 +368,7 @@ def update_task_state(self, key: TaskInstanceKey, state: str, info: Any) -> None
                 self.success(key, info)
             elif state in (celery_states.FAILURE, celery_states.REVOKED):
                 self.fail(key, info)
-            elif state in (celery_states.STARTEDstate, celery_states.PENDING):
+            elif state in (celery_states.STARTED, celery_states.PENDING):
                 pass
             else:
                 self.log.info("Unexpected state for %s: %s", key, state)