This is an automated email from the ASF dual-hosted git repository.
pierrejeambrun pushed a change to branch
jason/lang-sdk-e2e/03a-dag-processor-base
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 0649a43f468 Move the Dag file processor's shared plumbing into a base
class
omit 20603491841 Pin the empty task id case in the Dag cycle detection tests
omit 737097a0dfe Share Dag cycle detection between the Task SDK and core
add 383a9a87a98 Stop wiping the uv cache before every CI image build
(#74052)
add 58e987defec Fix Non-DB test collection failure in Google Stackdriver
hook test (#74066)
add 498724fc13a Go SDK: enumerate every user-facing enum in the airflow
package (#74064)
add 5e476d7cf89 TS SDK: answer the Dag-parsing request from bundle.serve
(#73442)
add dd271599939 Go SDK: vendor the schemas it generates from (#74047)
add 77927390c17 Move Dag cycle detection from the Task SDK to shared
(#74034)
add 7c112fe041f Move the Dag file processor's shared plumbing into a base
class
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 (0649a43f468)
\
N -- N -- N refs/heads/jason/lang-sdk-e2e/03a-dag-processor-base
(7c112fe041f)
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:
.pre-commit-config.yaml | 25 ++-
.../airflow_breeze/commands/ci_image_commands.py | 4 +-
dev/breeze/tests/test_ci_image_commands.py | 20 ++
go-sdk/README.md | 52 +++--
go-sdk/adr/0008-native-dag-interface.md | 5 +
go-sdk/airflow/dag.go | 5 +
go-sdk/airflow/enums.go | 156 +++++++++++++++
go-sdk/airflow/enums_test.go | 221 +++++++++++++++++++++
go-sdk/airflow/spec.go | 33 +--
go-sdk/airflow/spec_test.go | 71 -------
go-sdk/airflow/trigger_dag_run.go | 36 ++--
go-sdk/airflow/trigger_dag_run_test.go | 24 +--
go-sdk/internal/genspec/authoring.go | 6 +-
go-sdk/internal/genspec/main.go | 9 +-
go-sdk/internal/genspec/normalize_test.go | 5 +-
go-sdk/pkg/execution/genmodels/gen.go | 13 +-
go-sdk/pkg/execution/messages_test.go | 23 +--
{java-sdk/sdk => go-sdk}/schema/dag-schema.json | 0
.../schema/supervisor-schema.json | 0
.../unit/google/cloud/hooks/test_stackdriver.py | 2 +-
scripts/ci/prek/check_go_sdk_generated_drift.py | 25 ++-
scripts/ci/prek/sync_go_sdk_schemas.py | 142 +++++++++++++
.../ci/prek/test_check_go_sdk_generated_drift.py | 13 +-
scripts/tests/ci/prek/test_sync_go_sdk_schemas.py | 127 ++++++++++++
ts-sdk/src/coordinator/runtime.ts | 69 ++++++-
ts-sdk/tests/coordinator/integration.test.ts | 108 +++++++++-
26 files changed, 979 insertions(+), 215 deletions(-)
create mode 100644 go-sdk/airflow/enums.go
create mode 100644 go-sdk/airflow/enums_test.go
delete mode 100644 go-sdk/airflow/spec_test.go
copy {java-sdk/sdk => go-sdk}/schema/dag-schema.json (100%)
copy task-sdk/src/airflow/sdk/execution_time/schema/schema.json =>
go-sdk/schema/supervisor-schema.json (100%)
create mode 100755 scripts/ci/prek/sync_go_sdk_schemas.py
create mode 100644 scripts/tests/ci/prek/test_sync_go_sdk_schemas.py
