This is an automated email from the ASF dual-hosted git repository.
jason810496 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 3eabbb59586 Replace retired gemini-2.0-flash example model in
common.ai Vertex docs (#73516)
add 83b30710faf Go SDK: replace BundleProvider with airflow.Bundle and
TaskHandler (#73426)
No new revisions were added by this update.
Summary of changes:
go-sdk/adr/0001-bundle-packing-options.md | 4 +-
go-sdk/airflow/bundle.go | 130 ++++++++++
go-sdk/airflow/bundle_test.go | 182 ++++++++++++++
go-sdk/airflow/context.go | 5 +
go-sdk/airflow/contexttest_test.go | 62 +++++
.../bundlev1server/server.go => airflow/serve.go} | 138 ++++++-----
go-sdk/airflow/serve_test.go | 265 +++++++++++++++++++++
go-sdk/airflow/task_handler.go | 63 +++++
go-sdk/airflow/task_handler_test.go | 249 +++++++++++++++++++
.../testdata/foreignitem/main.go} | 20 +-
.../bundle/bundlev1/bundlev1server/server_test.go | 46 ----
go-sdk/bundle/bundlev1/registry.go | 204 ----------------
go-sdk/bundle/bundlev1/registry_test.go | 168 -------------
go-sdk/bundle/bundlev1/schemas.go | 46 ----
go-sdk/example/bundle/main.go | 82 ++++---
.../bundlev1server => internal/bundle}/doc.go | 9 +-
.../{bundle/bundlev1 => internal/bundle}/task.go | 22 +-
.../bundlev1 => internal/bundle}/task_test.go | 28 ++-
go-sdk/internal/contexttest/contexttest.go | 60 +++++
go-sdk/pkg/binding/binding.go | 8 +-
go-sdk/pkg/binding/binding_test.go | 165 +++++++------
go-sdk/pkg/binding/task_context.go | 68 ++++++
go-sdk/pkg/binding/task_context_test.go | 56 +++++
go-sdk/pkg/execution/integration_test.go | 236 +++++++++---------
go-sdk/pkg/execution/metadata.go | 56 ++---
go-sdk/pkg/execution/server.go | 27 +--
go-sdk/pkg/execution/task_runner.go | 8 +-
kubernetes-tests/lang_sdk/go_example/main.go | 24 +-
28 files changed, 1547 insertions(+), 884 deletions(-)
create mode 100644 go-sdk/airflow/bundle.go
create mode 100644 go-sdk/airflow/bundle_test.go
create mode 100644 go-sdk/airflow/contexttest_test.go
rename go-sdk/{bundle/bundlev1/bundlev1server/server.go => airflow/serve.go}
(53%)
create mode 100644 go-sdk/airflow/serve_test.go
create mode 100644 go-sdk/airflow/task_handler.go
create mode 100644 go-sdk/airflow/task_handler_test.go
rename go-sdk/{bundle/bundlev1/doc.go => airflow/testdata/foreignitem/main.go}
(59%)
delete mode 100644 go-sdk/bundle/bundlev1/bundlev1server/server_test.go
delete mode 100644 go-sdk/bundle/bundlev1/registry.go
delete mode 100644 go-sdk/bundle/bundlev1/registry_test.go
delete mode 100644 go-sdk/bundle/bundlev1/schemas.go
rename go-sdk/{bundle/bundlev1/bundlev1server => internal/bundle}/doc.go (75%)
rename go-sdk/{bundle/bundlev1 => internal/bundle}/task.go (87%)
rename go-sdk/{bundle/bundlev1 => internal/bundle}/task_test.go (86%)
create mode 100644 go-sdk/internal/contexttest/contexttest.go
create mode 100644 go-sdk/pkg/binding/task_context.go
create mode 100644 go-sdk/pkg/binding/task_context_test.go
