mhenc opened a new pull request #21301: URL: https://github.com/apache/airflow/pull/21301
This change refactors code, to prepare for DAG Processor separation: - move sending callbacks to dedicated 'PipeCallbacksSink' class. In a follow-up change, I will introduce DatabaseCallbacksSink which will send them to the Database. - introduce send_callback_to_execute for BaseExecutore - with default implementations. It can be overriden by Executor subclass. Part of AIP-43 https://cwiki.apache.org/confluence/display/AIRFLOW/AIP-43+DAG+Processor+separation -- 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]
