This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch jason/java-sdk/pack-dag-sources
in repository https://gitbox.apache.org/repos/asf/airflow.git
omit 5c11685b7bb Java SDK: Show each Dag's own source and find it outside
the package layout
omit 373107ed495 Java SDK: Bound the describe run and keep its payload to
the bundle JAR
omit 5d130b3d915 Java SDK: Pack each native Dag's source file into the
bundle JAR
omit 5c62c64d00f Java SDK: Record the class that declares each Dag and
describe it on request
omit f1f528fe138 Java SDK: Accept every cron schedule croniter does and
bind wired inputs first
omit b3b6ed54fd0 Java SDK: Mark the native Dag capabilities as shipping in
3.4
omit 165e39d2351 Java SDK: Keep one unserializable Dag from failing a whole
bundle's parse
omit f8ed44be37b Java SDK: Carry a native Dag's call arguments as argument
bindings
omit 1d269c8fe1d Java SDK: Build a native Dag's timetable the way Python
does
omit 7b05fa912e3 Java SDK: Run the serialization conformance check on every
file that steers it
omit 9b4b4804b55 Java SDK: Check native Dag serialization against Airflow's
omit d516f21edd9 Java SDK: Write each Dag tag once, as Python does
omit 7ffa0f4509a Java SDK: Serialize a native Dag's task groups
omit 509050aeb3e Java SDK: Leave out the email flags a Java task cannot act
on
omit 6c6108e8c40 Java SDK: Leave config-backed Dag fields for Airflow to
fill in
omit b4e382ad87d Test that the conformance check compares Dag params
omit 5b242ea7734 Java SDK: Serialize native Dags to DagSerialization v3 on
parse requests
add 1921597eeff Go SDK: embed each native Dag's source file in the bundle
(#74342)
add 01b977568e2 Java SDK: Serialize native Dags to DagSerialization v3
(#71190)
add 9eeda412da4 Java SDK: Record the class that declares each Dag and
describe it on request
add 030a0702bd7 Java SDK: Pack each native Dag's source file into the
bundle JAR
add d36ca2cd9a6 Java SDK: Bound the describe run and keep its payload to
the bundle JAR
add 10a695499b0 Java SDK: Show each Dag's own source and find it outside
the package layout
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 (5c11685b7bb)
\
N -- N -- N refs/heads/jason/java-sdk/pack-dag-sources
(10a695499b0)
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:
.../0015-per-dag-source-in-bundle-artifact.md | 13 +-
.../authoring-and-scheduling/language-sdks/go.rst | 5 +-
go-sdk/README.md | 4 +-
go-sdk/airflow/bundle.go | 53 ++-
go-sdk/airflow/bundle_test.go | 27 ++
go-sdk/airflow/dag.go | 11 +-
.../level.go => airflow/dag_factory_test.go} | 11 +-
go-sdk/airflow/dag_source_test.go | 65 ++++
go-sdk/airflow/serve.go | 6 +-
go-sdk/cmd/airflow-go-pack/inspect.go | 59 ++-
go-sdk/cmd/airflow-go-pack/inspect_test.go | 89 ++++-
go-sdk/cmd/airflow-go-pack/main.go | 9 +-
go-sdk/cmd/airflow-go-pack/pack.go | 123 ++++--
.../cmd/airflow-go-pack/pack_integration_test.go | 21 +-
go-sdk/cmd/airflow-go-pack/pack_test.go | 102 ++++-
go-sdk/cmd/airflow-go-pack/sources.go | 256 ++++++++++++
go-sdk/cmd/airflow-go-pack/sources_test.go | 430 +++++++++++++++++++++
.../airflow-go-pack/testdata/handlersonly/main.go} | 23 +-
.../testdata/multidag/factory/factory.go} | 18 +-
.../airflow-go-pack/testdata/multidag}/main.go | 38 +-
.../testdata/multidag/reports/reports.go} | 18 +-
go-sdk/example/bundle/Justfile | 4 +-
go-sdk/internal/airflowmetadata/airflowmetadata.go | 3 +
go-sdk/internal/bundle/doc.go | 9 +-
go-sdk/internal/bundle/task.go | 5 +
go-sdk/pkg/execution/metadata.go | 5 +
go-sdk/pkg/execution/metadata_test.go | 36 ++
27 files changed, 1304 insertions(+), 139 deletions(-)
copy go-sdk/{pkg/logging/level.go => airflow/dag_factory_test.go} (79%)
create mode 100644 go-sdk/airflow/dag_source_test.go
create mode 100644 go-sdk/cmd/airflow-go-pack/sources.go
create mode 100644 go-sdk/cmd/airflow-go-pack/sources_test.go
copy go-sdk/{pkg/logging/attrs.go =>
cmd/airflow-go-pack/testdata/handlersonly/main.go} (65%)
copy go-sdk/{pkg/logging/attrs.go =>
cmd/airflow-go-pack/testdata/multidag/factory/factory.go} (74%)
copy go-sdk/{airflow/testdata/foreignnode =>
cmd/airflow-go-pack/testdata/multidag}/main.go (56%)
copy go-sdk/{pkg/logging/attrs.go =>
cmd/airflow-go-pack/testdata/multidag/reports/reports.go} (73%)
