This is an automated email from the ASF dual-hosted git repository.
potiuk 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 f463e2a0dd Remove state sync during celery task processing (#41870)
f463e2a0dd is described below
commit f463e2a0dde51581a5a03e8d511e6a2603d51393
Author: Kyle Thatcher <[email protected]>
AuthorDate: Tue Oct 1 20:46:16 2024 -0400
Remove state sync during celery task processing (#41870)
---
airflow/providers/celery/executors/celery_executor.py | 3 ---
1 file changed, 3 deletions(-)
diff --git a/airflow/providers/celery/executors/celery_executor.py
b/airflow/providers/celery/executors/celery_executor.py
index 93037bb31c..807c77ab98 100644
--- a/airflow/providers/celery/executors/celery_executor.py
+++ b/airflow/providers/celery/executors/celery_executor.py
@@ -300,9 +300,6 @@ class CeleryExecutor(BaseExecutor):
# which point we don't need the ID anymore anyway
self.event_buffer[key] = (TaskInstanceState.QUEUED,
result.task_id)
- # If the task runs _really quickly_ we may already have a
result!
- self.update_task_state(key, result.state, getattr(result,
"info", None))
-
def _send_tasks_to_celery(self, task_tuples_to_send:
list[TaskInstanceInCelery]):
from airflow.providers.celery.executors.celery_executor_utils import
send_task_to_executor
