mirror of
https://github.com/apache/airflow.git
synced 2026-11-04 16:01:19 +00:00
D. Ferruzzi
ec6700db07
* Move ExecutorCallback execution into a supervised process and make the entire flow more generic to account for future workload types * merge conflict whitespace oops * moved runtime error into supervise_callback() * add some context tot eh comment about not supporting message types * Copilot review fixes * Improve callback display name * remove execute_callback from export * Shivam fixes * static checks * fix Core/SDK barrier issues * Ash fixes - create supervise_workload and move setproctitle in there as well * merge conflict fixes adn mypy * fix unit tests * add running state back * account for *args in accepts_context * fix encoder * fix context, use closure for subprocess, and plumb callback logs through to the scheduler * fix dequeue cleanup * Kaxil fixes rnd 2 - move bundle loading into start() - add _make_process_nondumpable to supervise_callback - fix context passing to callback_callable - revert adding *args check to accepts_context - parameterize tests - top-leveled some imports * move run_workload in to base_executor for SDK/Core split policy * somehow missed this file in the commit * mypy fix * kaxil fixes rnd 3 * compat test fix * replace mock with actual object * fix celery compat issues * switch from log to _log