atul-astronomer commented on issue #49047: URL: https://github.com/apache/airflow/issues/49047#issuecomment-2872166183
Tried replicating on main latest: 1. Backfill is still trying to run previous version task. 2. Duplicate task retires are coming on UI.  **Scheduler**: `[2025-05-12T11:18:14.105+0000] {scheduler_job_runner.py:925} ERROR - DAG 'test_asset_event_producer' for task instance <TaskInstance: test_asset_event_producer.asset_with_extra_by_yield scheduled__2025-05-11T00:00:00+00:00 [queued]> not found in serialized_dag table [2025-05-12T11:18:14.106+0000] {taskinstance.py:2468} ERROR - Executor CeleryExecutor(parallelism=32) reported that the task instance <TaskInstance: test_asset_event_producer.asset_with_extra_by_yield scheduled__2025-05-11T00:00:00+00:00 [queued]> finished with state failed, but the task instance's state attribute is queued. Learn more: https://airflow.apache.org/docs/apache-airflow/stable/troubleshooting.html#task-state-changed-externally ` **API server**: `File "/usr/local/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 967, in run result = context.run(func, *args) File "/usr/local/lib/python3.9/site-packages/cadwyn/schema_generation.py", line 511, in __call__ return self._original_callable(*args, **kwargs) File "/opt/airflow/airflow-core/src/airflow/api_fastapi/execution_api/routes/task_instances.py", line 247, in ti_run upstream_map_indexes = dict(_get_upstream_map_indexes(dag.get_task(ti.task_id), ti.map_index)) File "/opt/airflow/task-sdk/src/airflow/sdk/definitions/dag.py", line 900, in get_task raise TaskNotFound(f"Task {task_id} not found") airflow.exceptions.TaskNotFound: Task asset_with_extra_by_yield not found ` @vatsrahul1001 @sunank200 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
