fat-catTW commented on PR #70280: URL: https://github.com/apache/airflow/pull/70280#issuecomment-5217596792
Good catch, thanks for review. I changed this so `ExecuteTask.make()` no longer reads from `ti.task`. The scheduler now resolves the task from the serialized Dag during enqueue, reads `execute_tasks_new_python_interpreter` from that serialized task, and passes the value explicitly into `ExecuteTask.make()`. If the serialized Dag or task is unavailable, it falls back to `None`, so the existing global config fallback behavior is preserved. -- 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]
