uranusjr commented on issue #25207: URL: https://github.com/apache/airflow/issues/25207#issuecomment-1191106777
> I cant figure out where we deserialize or recreate the callback methods for `on_success/failure` The actual callbacks are _not set_ on the deserialized/recreated DAG because it’s impossible to do without importing the original DAG files. Airflow only imports the DAG files in worker processes so user code is never run in the scheduler (which always only use deserialized DAGs). Thosee callbacks are instead executed by the DAG processor process, which imports the DAG files and thus has access to the actual Python function object. -- 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]
