This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a change to branch execution-time-code-in-task-sdk
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard d2af0a5338e Use Pydantic and Gen client code
discard 7959e49cc92 fixup! Code reviews
discard a16ec2b7eba Add tests for error handling of our api Client
discard 9b3c8723f64 Code reviews
discard a7f07a32cb4 Start building the replacement task runner for Task
Execution SDK
add 4af2c27656f Refactor DagRun tracing into `_trace_dagrun` helper method
(#44008)
add c84d35622cc AIP 84: Migrate GET one ASSET legacy API to fast API
(#43825)
add c94715fdc6b fix(scheduler_job_runner/asset): fix how asset dag warning
is added (#43873)
add 37d58f72dc9 Start building the replacement task runner for Task
Execution SDK
add 908e8e2fee6 Code reviews
add ac08dad1dcc Add tests for error handling of our api Client
add 51cb9ad821e fixup! Code reviews
add 50a0d12b9c8 Use Pydantic and Gen client code
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d2af0a5338e)
\
N -- N -- N refs/heads/execution-time-code-in-task-sdk
(50a0d12b9c8)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
airflow/api_connexion/endpoints/asset_endpoint.py | 1 +
.../api_fastapi/core_api/openapi/v1-generated.yaml | 45 +++++++++
.../api_fastapi/core_api/routes/public/assets.py | 32 +++++-
airflow/jobs/scheduler_job_runner.py | 35 ++++---
airflow/models/dagrun.py | 59 +++++------
airflow/models/dagwarning.py | 2 +-
airflow/ui/openapi-gen/queries/common.ts | 16 +++
airflow/ui/openapi-gen/queries/prefetch.ts | 20 ++++
airflow/ui/openapi-gen/queries/queries.ts | 26 +++++
airflow/ui/openapi-gen/queries/suspense.ts | 26 +++++
airflow/ui/openapi-gen/requests/services.gen.ts | 28 ++++++
airflow/ui/openapi-gen/requests/types.gen.ts | 33 +++++++
task_sdk/src/airflow/sdk/api/client.py | 14 +--
.../src/airflow/sdk/api/datamodels/activities.py | 4 +-
task_sdk/src/airflow/sdk/api/datamodels/ti.py | 7 +-
task_sdk/src/airflow/sdk/execution_time/comms.py | 47 ++++++---
.../src/airflow/sdk/execution_time/supervisor.py | 30 ++++--
.../src/airflow/sdk/execution_time/task_runner.py | 23 ++---
task_sdk/tests/execution_time/test_supervisor.py | 4 +-
task_sdk/tests/execution_time/test_task_runner.py | 7 +-
.../core_api/routes/public/test_assets.py | 42 ++++++++
tests/jobs/test_scheduler_job.py | 109 +++++++++++++++++++++
tests/models/test_dag.py | 22 ++---
23 files changed, 520 insertions(+), 112 deletions(-)
