vatsrahul1001 commented on issue #47832:
URL: https://github.com/apache/airflow/issues/47832#issuecomment-2728064155

   @uranusjr we were noticing the different error in scheduler when we tested 
this scenario
   
   ```
     File "/opt/airflow/airflow/jobs/scheduler_job_runner.py", line 880, in 
process_executor_events
       ti.handle_failure(error=msg, session=session)
     File "/opt/airflow/airflow/utils/session.py", line 98, in wrapper
       return func(*args, **kwargs)
     File "/opt/airflow/airflow/models/taskinstance.py", line 3206, in 
handle_failure
       _handle_failure(
     File "/opt/airflow/airflow/utils/session.py", line 98, in wrapper
       return func(*args, **kwargs)
     File "/opt/airflow/airflow/models/taskinstance.py", line 1073, in 
_handle_failure
       failure_context = TaskInstance.fetch_handle_failure_context(
     File "/opt/airflow/airflow/models/taskinstance.py", line 3114, in 
fetch_handle_failure_context
       context = ti.get_template_context(session)
     File "/opt/airflow/airflow/models/taskinstance.py", line 3234, in 
get_template_context
       return _get_template_context(
     File "/opt/airflow/airflow/models/taskinstance.py", line 935, in 
_get_template_context
       context: Context = runtime_ti.get_template_context()
     File 
"/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py", line 
148, in get_template_context
       "inlet_events": InletEventsAccessors(self.task.inlets),
     File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/context.py", 
line 302, in __init__
       asset = OutletEventAccessors._get_asset_from_db(name=inlet.name)
     File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/context.py", 
line 267, in _get_asset_from_db
       from airflow.sdk.execution_time.task_runner import SUPERVISOR_COMMS
   ImportError: cannot import name 'SUPERVISOR_COMMS' from 
'airflow.sdk.execution_time.task_runner' 
(/opt/airflow/task-sdk/src/airflow/sdk/execution_time/task_runner.py)
   root@a799eb98b17f:/opt/airflow#
   ```


-- 
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]

Reply via email to