This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from af94629c922 Add Hebrew translation for dag.json (#51839)
add 492518edfae Switch the Supervisor/task process from line-based to
length-prefixed (#51699)
No new revisions were added by this update.
Summary of changes:
airflow-core/src/airflow/dag_processing/manager.py | 9 +-
.../src/airflow/dag_processing/processor.py | 33 ++-
.../src/airflow/jobs/triggerer_job_runner.py | 126 ++++----
.../tests/unit/dag_processing/test_manager.py | 81 +++--
.../tests/unit/dag_processing/test_processor.py | 51 ++--
airflow-core/tests/unit/hooks/test_base.py | 13 +-
airflow-core/tests/unit/jobs/test_triggerer_job.py | 34 +--
.../tests/unit/models/test_taskinstance.py | 4 +-
devel-common/src/tests_common/pytest_plugin.py | 24 +-
.../tests/unit/amazon/aws/links/test_athena.py | 2 +-
.../tests/unit/amazon/aws/links/test_batch.py | 6 +-
.../tests/unit/amazon/aws/links/test_comprehend.py | 4 +-
.../tests/unit/amazon/aws/links/test_datasync.py | 4 +-
.../amazon/tests/unit/amazon/aws/links/test_ec2.py | 4 +-
.../amazon/tests/unit/amazon/aws/links/test_emr.py | 12 +-
.../tests/unit/amazon/aws/links/test_glue.py | 2 +-
.../tests/unit/amazon/aws/links/test_logs.py | 2 +-
.../tests/unit/amazon/aws/links/test_sagemaker.py | 2 +-
.../aws/links/test_sagemaker_unified_studio.py | 2 +-
.../unit/amazon/aws/links/test_step_function.py | 4 +-
.../io/tests/unit/common/io/xcom/test_backend.py | 19 +-
.../tests/unit/dbt/cloud/operators/test_dbt.py | 2 +-
.../unit/google/cloud/links/test_cloud_run.py | 2 +-
.../tests/unit/google/cloud/links/test_dataplex.py | 20 +-
.../unit/google/cloud/links/test_translate.py | 8 +-
.../unit/google/cloud/operators/test_dataproc.py | 20 +-
.../microsoft/azure/operators/test_data_factory.py | 2 +-
.../unit/microsoft/azure/operators/test_synapse.py | 2 +-
task-sdk/pyproject.toml | 1 -
task-sdk/src/airflow/sdk/bases/xcom.py | 98 +++---
.../airflow/sdk/definitions/asset/decorators.py | 14 +-
task-sdk/src/airflow/sdk/execution_time/comms.py | 165 ++++++++++-
task-sdk/src/airflow/sdk/execution_time/context.py | 76 ++---
.../airflow/sdk/execution_time/lazy_sequence.py | 60 ++--
.../src/airflow/sdk/execution_time/supervisor.py | 294 ++++++++++--------
.../src/airflow/sdk/execution_time/task_runner.py | 219 +++++---------
task-sdk/tests/task_sdk/bases/test_sensor.py | 10 +-
task-sdk/tests/task_sdk/definitions/conftest.py | 6 +-
.../task_sdk/definitions/test_asset_decorators.py | 16 +-
.../tests/task_sdk/definitions/test_connections.py | 2 +-
.../task_sdk/definitions/test_mappedoperator.py | 41 ++-
.../tests/task_sdk/definitions/test_variables.py | 5 +-
.../tests/task_sdk/definitions/test_xcom_arg.py | 36 +--
.../tests/task_sdk/execution_time/test_comms.py | 83 ++++++
.../tests/task_sdk/execution_time/test_context.py | 85 +++---
.../task_sdk/execution_time/test_lazy_sequence.py | 140 ++++-----
.../task_sdk/execution_time/test_supervisor.py | 329 +++++++++++----------
.../task_sdk/execution_time/test_task_runner.py | 293 ++++++------------
48 files changed, 1249 insertions(+), 1218 deletions(-)
create mode 100644 task-sdk/tests/task_sdk/execution_time/test_comms.py
