You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by as...@apache.org on 2024/10/29 16:14:34 UTC
(airflow) branch task-sdk-first-code updated (fc8645e5f2 -> 67685412ff)
This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch task-sdk-first-code
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard fc8645e5f2 [skip-ci]
discard 4f1bd23e42 Fix tests [skip ci]
discard 0315fff56d [skip-ci]
discard 4de947b99e [skip-ci]
discard 2c984cc596 fixup! Fix AirflowExecption error in tests/models/test_taskinstance.py
discard ffb0640d93 [skip-ci]
discard ee5876ae39 Fix AirflowExecption error in tests/models/test_taskinstance.py
discard 3acfb5c9b7 fix some tests [skip ci]
discard 16cfa32862 Fix serialization
discard 459a24ebfc Fix mypy typing
discard 4ab817b01b Fix default pool
discard b3b7cc58b4 make mpypy happy [skip ci]
discard cd6c3f01a6 fix more stest [skip-ci]
discard f123f6e325 Update pre-commit scripts.
discard c2fbcf8a7d Use attrs converters for access_control [skip ci]
discard e30c992496 [skip-ci]
discard 016e01f421 Replace DagContext from core to Task SDK [skip ci]
discard 5867b1e963 Use DAG Context from Task SDK [skip ci]
discard cd62a487c2 More fixes to test_dagbag.py [skip ci]
discard 934c9ec814 [skip ci]
discard 03e6959845 Fix some tests in tests/models/test_dagbag.py [ci skip]
discard 5850bca223 [skip ci]
discard 8bd96e7150 [skip ci]
discard 817a36e6a3 Get more tests passing
discard c587c307a3 Start porting over all the DAG defintion code to the Task SDK
add 96aae9718f Edge worker graceful shutdown on version mismatch (#43462)
add baf2b3cb44 fix(providers/fab): alias is_authorized_dataset to is_authorized_asset (#43469)
add 39dba929bb fix(providers/amazon): alias is_authorized_dataset to is_authorized_asset (#43470)
add b0a8605b35 AIP-84 Get Event Log (#43406)
add 755c10b997 Fix docstring for `TI.fetch_handle_failure_context` (#43481)
add 3e4b344b2f AIP-84 Migrate Modify Dag Run endpoint to FastAPI (#42973)
add 1badaec151 Fix oracle bulk insert issue when leftover chunk is empty (#43467)
add 56fc220794 Start porting over all the DAG defintion code to the Task SDK
add 55e60c4ce8 Get more tests passing
add 4c022d3127 [skip ci]
add b6b6e221c4 [skip ci]
add afe16fdb54 Fix some tests in tests/models/test_dagbag.py [ci skip]
add 687ba401af [skip ci]
add 3bfe222a94 More fixes to test_dagbag.py [skip ci]
add 6cfffe2ecb Use DAG Context from Task SDK [skip ci]
add 3802cab333 Replace DagContext from core to Task SDK [skip ci]
add a520cd26c0 [skip-ci]
add 341042f313 Use attrs converters for access_control [skip ci]
add e17b73ea0f Update pre-commit scripts.
add b2f0f1e7a2 fix more stest [skip-ci]
add 21e05f42ea make mpypy happy [skip ci]
add e565839bcd Fix default pool
add d13ea208d1 Fix mypy typing
add 377f10870e Fix serialization
add 13245e69da fix some tests [skip ci]
add 32c38713aa Fix AirflowExecption error in tests/models/test_taskinstance.py
add 7d83602104 [skip-ci]
add 6d1149323a [skip-ci]
add df2641dc0b [skip-ci]
add 3d5837aa8b Fix tests [skip ci]
add 44b9fff01d [skip-ci]
add 67685412ff fix-non db tests
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 (fc8645e5f2)
\
N -- N -- N refs/heads/task-sdk-first-code (67685412ff)
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:
.../api_connexion/endpoints/dag_run_endpoint.py | 1 +
.../api_connexion/endpoints/event_log_endpoint.py | 2 +
.../api_fastapi/core_api/openapi/v1-generated.yaml | 201 +++++++++++++++++++++
.../api_fastapi/core_api/routes/public/__init__.py | 2 +
.../api_fastapi/core_api/routes/public/dag_run.py | 57 +++++-
.../core_api/routes/public/event_logs.py | 51 ++++++
.../api_fastapi/core_api/serializers/dag_run.py | 15 ++
.../core_api/serializers/event_logs.py} | 29 +--
airflow/models/taskinstance.py | 10 +-
airflow/ui/openapi-gen/queries/common.ts | 20 ++
airflow/ui/openapi-gen/queries/prefetch.ts | 20 ++
airflow/ui/openapi-gen/queries/queries.ts | 81 +++++++++
airflow/ui/openapi-gen/queries/suspense.ts | 29 +++
airflow/ui/openapi-gen/requests/schemas.gen.ts | 142 +++++++++++++++
airflow/ui/openapi-gen/requests/services.gen.ts | 67 +++++++
airflow/ui/openapi-gen/requests/types.gen.ts | 100 ++++++++++
.../amazon/aws/auth_manager/aws_auth_manager.py | 13 +-
providers/src/airflow/providers/edge/CHANGELOG.rst | 8 +
providers/src/airflow/providers/edge/__init__.py | 2 +-
.../src/airflow/providers/edge/cli/edge_command.py | 16 +-
.../airflow/providers/edge/models/edge_worker.py | 2 +-
providers/src/airflow/providers/edge/provider.yaml | 2 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 13 +-
.../src/airflow/providers/oracle/hooks/oracle.py | 9 +-
providers/tests/amazon/aws/operators/test_batch.py | 2 +-
providers/tests/edge/cli/test_edge_command.py | 8 +-
providers/tests/fab/auth_manager/views/__init__.py | 17 ++
.../fab/auth_manager/views/test_permissions.py | 13 +-
.../fab/auth_manager/views/test_roles_list.py | 5 +-
.../tests/fab/auth_manager/views/test_user.py | 5 +-
.../tests/fab/auth_manager/views/test_user_edit.py | 4 +-
.../fab/auth_manager/views/test_user_stats.py | 4 +-
.../google/cloud/operators/test_cloud_build.py | 4 +-
.../tests/google/cloud/operators/test_compute.py | 8 +-
.../tests/google/cloud/operators/test_dataproc.py | 6 +-
.../cloud/operators/test_kubernetes_engine.py | 12 +-
.../google/cloud/operators/test_speech_to_text.py | 11 +-
.../tests/google/cloud/sensors/test_dataproc.py | 2 +-
.../google/cloud/transfers/test_gcs_to_bigquery.py | 8 +-
providers/tests/oracle/hooks/test_oracle.py | 18 ++
providers/tests/salesforce/operators/test_bulk.py | 5 +-
.../core_api/routes/public/test_dag_run.py | 50 +++++
.../core_api/routes/public/test_event_logs.py | 177 ++++++++++++++++++
tests/serialization/test_dag_serialization.py | 5 +
44 files changed, 1183 insertions(+), 73 deletions(-)
create mode 100644 airflow/api_fastapi/core_api/routes/public/event_logs.py
copy airflow/{example_dags/example_dynamic_task_mapping.py => api_fastapi/core_api/serializers/event_logs.py} (63%)
create mode 100644 tests/api_fastapi/core_api/routes/public/test_event_logs.py