This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from b113006af61 Prepare openlineage to release (#56090)
add bd60584ceac Separate out Go tasks and Go worker in to separate
processes (#56079)
No new revisions were added by this update.
Summary of changes:
go-sdk/.mockery.yml | 7 +-
go-sdk/.pre-commit-config.yaml | 14 +-
go-sdk/Justfile | 26 +
go-sdk/README.md | 8 +-
go-sdk/bin/.gitignore | 2 +
.../{sdk => bundle/bundlev1/bundlev1client}/doc.go | 9 +-
go-sdk/bundle/bundlev1/bundlev1client/grpc.go | 126 +++
.../{sdk => bundle/bundlev1/bundlev1server}/doc.go | 12 +-
.../bundle/bundlev1/bundlev1server/impl/plugin.go | 189 ++++
go-sdk/bundle/bundlev1/bundlev1server/server.go | 103 ++
go-sdk/{pkg/api/init.go => bundle/bundlev1/doc.go} | 30 +-
go-sdk/{worker => bundle/bundlev1}/registry.go | 52 +-
go-sdk/bundle/bundlev1/registry_test.go | 120 +++
go-sdk/bundle/bundlev1/schemas.go | 57 +
go-sdk/{worker => bundle/bundlev1}/task.go | 2 +-
go-sdk/{worker => bundle/bundlev1}/task_test.go | 2 +-
go-sdk/celery/app.go | 78 +-
go-sdk/{sdk/doc.go => celery/cmd/main.go} | 11 +-
go-sdk/celery/commands/root.go | 102 ++
go-sdk/celery/{cmd => commands}/run.go | 20 +-
go-sdk/celery/config.go | 7 +-
go-sdk/example/bundle/Justfile | 16 +
go-sdk/example/{ => bundle}/main.go | 57 +-
go-sdk/example/{ => bundle}/main_test.go | 0
go-sdk/go.mod | 11 +-
go-sdk/go.sum | 26 +
go-sdk/internal/protov1/plugin.pb.go | 1121 ++++++++++++++++++++
go-sdk/internal/protov1/plugin.proto | 65 ++
go-sdk/internal/protov1/plugin_grpc.pb.go | 165 +++
.../cmd/root.go => pkg/bundles/shared/config.go} | 77 +-
go-sdk/pkg/bundles/shared/discovery.go | 252 +++++
.../{api/init.go => bundles/shared/handshake.go} | 29 +-
go-sdk/pkg/logging/shclog/shclog.go | 241 +++++
go-sdk/{ => pkg}/worker/init.go | 0
go-sdk/{ => pkg}/worker/runner.go | 125 ++-
go-sdk/{ => pkg}/worker/runner_test.go | 31 +-
go-sdk/{ => pkg}/worker/task.go | 13 +-
go-sdk/{ => pkg}/worker/task_test.go | 0
go-sdk/worker/mocks/Registry.go | 203 ----
go-sdk/worker/mocks/Task.go | 96 --
go-sdk/worker/mocks/Worker.go | 325 ------
go-sdk/worker/registry_test.go | 67 --
42 files changed, 2950 insertions(+), 947 deletions(-)
create mode 100644 go-sdk/Justfile
create mode 100644 go-sdk/bin/.gitignore
copy go-sdk/{sdk => bundle/bundlev1/bundlev1client}/doc.go (72%)
create mode 100644 go-sdk/bundle/bundlev1/bundlev1client/grpc.go
copy go-sdk/{sdk => bundle/bundlev1/bundlev1server}/doc.go (67%)
create mode 100644 go-sdk/bundle/bundlev1/bundlev1server/impl/plugin.go
create mode 100644 go-sdk/bundle/bundlev1/bundlev1server/server.go
copy go-sdk/{pkg/api/init.go => bundle/bundlev1/doc.go} (69%)
rename go-sdk/{worker => bundle/bundlev1}/registry.go (66%)
create mode 100644 go-sdk/bundle/bundlev1/registry_test.go
create mode 100644 go-sdk/bundle/bundlev1/schemas.go
copy go-sdk/{worker => bundle/bundlev1}/task.go (99%)
copy go-sdk/{worker => bundle/bundlev1}/task_test.go (99%)
copy go-sdk/{sdk/doc.go => celery/cmd/main.go} (86%)
create mode 100644 go-sdk/celery/commands/root.go
rename go-sdk/celery/{cmd => commands}/run.go (72%)
create mode 100644 go-sdk/example/bundle/Justfile
rename go-sdk/example/{ => bundle}/main.go (74%)
rename go-sdk/example/{ => bundle}/main_test.go (100%)
create mode 100644 go-sdk/internal/protov1/plugin.pb.go
create mode 100644 go-sdk/internal/protov1/plugin.proto
create mode 100644 go-sdk/internal/protov1/plugin_grpc.pb.go
rename go-sdk/{celery/cmd/root.go => pkg/bundles/shared/config.go} (60%)
create mode 100644 go-sdk/pkg/bundles/shared/discovery.go
copy go-sdk/pkg/{api/init.go => bundles/shared/handshake.go} (65%)
create mode 100644 go-sdk/pkg/logging/shclog/shclog.go
rename go-sdk/{ => pkg}/worker/init.go (100%)
rename go-sdk/{ => pkg}/worker/runner.go (78%)
rename go-sdk/{ => pkg}/worker/runner_test.go (89%)
rename go-sdk/{ => pkg}/worker/task.go (96%)
rename go-sdk/{ => pkg}/worker/task_test.go (100%)
delete mode 100644 go-sdk/worker/mocks/Registry.go
delete mode 100644 go-sdk/worker/mocks/Task.go
delete mode 100644 go-sdk/worker/mocks/Worker.go
delete mode 100644 go-sdk/worker/registry_test.go
