This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from f4dfbf29bdc Handle logical_date=None rows when downgrading db (#46615)
add 0047a6886a1 change listener API, add basic support for task instance
listeners in TaskSDK, make OpenLineage provider support Airflow 3's listener
interface (#45294)
No new revisions were added by this update.
Summary of changes:
.../execution_api/datamodels/taskinstance.py | 4 +
.../execution_api/routes/task_instances.py | 36 +-
airflow/example_dags/plugins/event_listener.py | 44 +-
airflow/listeners/listener.py | 8 +-
airflow/listeners/spec/taskinstance.py | 15 +-
airflow/models/taskinstance.py | 7 +-
airflow/utils/context.py | 2 +
.../administration-and-deployment/listeners.rst | 20 +-
docs/apache-airflow/templates-ref.rst | 2 +
.../provider_tests/edge/cli/test_edge_command.py | 2 +
.../edge/executors/test_edge_executor.py | 1 +
.../providers/openlineage/plugins/listener.py | 227 ++-
.../openlineage/utils/selective_enable.py | 6 +-
.../airflow/providers/openlineage/utils/utils.py | 26 +-
.../openlineage/extractors/test_manager.py | 169 +-
.../openlineage/plugins/test_execution.py | 5 +-
.../openlineage/plugins/test_listener.py | 1693 +++++++++++++-------
.../airflow/providers/standard/operators/python.py | 5 +
scripts/ci/pre_commit/template_context_key_sync.py | 3 +
.../src/airflow/sdk/api/datamodels/_generated.py | 2 +
task_sdk/src/airflow/sdk/definitions/context.py | 2 +
task_sdk/src/airflow/sdk/execution_time/comms.py | 1 +
.../src/airflow/sdk/execution_time/supervisor.py | 7 +-
.../src/airflow/sdk/execution_time/task_runner.py | 63 +-
task_sdk/tests/conftest.py | 18 +-
task_sdk/tests/execution_time/test_supervisor.py | 129 +-
task_sdk/tests/execution_time/test_task_runner.py | 153 +-
.../execution_api/routes/test_task_instances.py | 3 +-
tests/callbacks/test_callback_requests.py | 1 +
tests/executors/test_local_executor.py | 3 +
tests/jobs/test_scheduler_job.py | 2 +
tests/listeners/class_listener.py | 8 +-
tests/listeners/empty_listener.py | 2 +-
tests/listeners/file_write_listener.py | 8 +-
tests/listeners/full_listener.py | 6 +-
tests/listeners/partial_listener.py | 2 +-
tests/listeners/slow_listener.py | 2 +-
tests/listeners/throwing_listener.py | 2 +-
tests/listeners/very_slow_listener.py | 2 +-
tests/listeners/xcom_listener.py | 4 +-
tests/plugins/test_plugins_manager.py | 29 +-
tests/utils/test_cli_util.py | 2 +-
tests_common/test_utils/compat.py | 2 +
43 files changed, 1925 insertions(+), 803 deletions(-)
