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 62d60e4af15 Fix Helm chart executor label to support executor aliases
(#67762)
add 70d269aadb7 Go-SDK: Add concurrent-safe coordinator comms, log
handler, and client (#67317)
No new revisions were added by this update.
Summary of changes:
go-sdk/pkg/execution/client.go | 232 +++++++++++
go-sdk/pkg/execution/client_test.go | 288 +++++++++++++
go-sdk/pkg/execution/comms.go | 276 +++++++++++++
go-sdk/pkg/execution/comms_test.go | 753 ++++++++++++++++++++++++++++++++++
go-sdk/pkg/execution/frames.go | 27 +-
go-sdk/pkg/execution/frames_test.go | 10 +-
go-sdk/pkg/execution/logger.go | 239 +++++++++++
go-sdk/pkg/execution/logger_test.go | 304 ++++++++++++++
go-sdk/pkg/execution/messages.go | 12 +-
go-sdk/pkg/execution/messages_test.go | 90 +++-
10 files changed, 2215 insertions(+), 16 deletions(-)
create mode 100644 go-sdk/pkg/execution/client.go
create mode 100644 go-sdk/pkg/execution/client_test.go
create mode 100644 go-sdk/pkg/execution/comms.go
create mode 100644 go-sdk/pkg/execution/comms_test.go
create mode 100644 go-sdk/pkg/execution/logger.go
create mode 100644 go-sdk/pkg/execution/logger_test.go