This is an automated email from the ASF dual-hosted git repository.
eladkal pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 50cccbdf44 Fix bad "code cleanup" in celery executor (#34192)
50cccbdf44 is described below
commit 50cccbdf4422c7a394709f5ce2f3d833dee16e9d
Author: Daniel Standish <[email protected]>
AuthorDate: Thu Sep 7 22:42:27 2023 -0700
Fix bad "code cleanup" in celery executor (#34192)
Fixes error introduced in code cleanup PR #33987
---
airflow/providers/celery/executors/celery_executor.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/providers/celery/executors/celery_executor.py
b/airflow/providers/celery/executors/celery_executor.py
index a2caf92c75..ef07891079 100644
--- a/airflow/providers/celery/executors/celery_executor.py
+++ b/airflow/providers/celery/executors/celery_executor.py
@@ -368,7 +368,7 @@ class CeleryExecutor(BaseExecutor):
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)
