The GitHub Actions job "Tests (AMD)" on 
airflow.git/refactor/go-sdk/coordinator-comms has failed.
Run started by GitHub user jason810496 (triggered by jason810496).

Head commit for run:
0dc467c040769ba43346fe3aae99cfa27813d2f8 / LIU ZHE YOU <[email protected]>
go-sdk: Add concurrent-safe coordinator comms, log handler, and client

Build the comm layer on top of the protocol primitives so subsequent
runtime code has a single typed entry point for talking to the supervisor.

CoordinatorComm runs a concurrent-safe dispatcher loop that fans inbound
frames out to per-request reply channels keyed by a monotonic id,
propagates context cancellation, and cleans up pending requests on
SendRequest failure. SocketLogHandler streams slog records as structured
JSON over the dedicated logs socket so the supervisor can demux task
logs without parsing stderr. CoordinatorClient implements the sdk.Client
surface (GetVariable honouring AIRFLOW_VAR_* overrides, GetConnection,
XCom push/pull, deferral) by routing each method through the dispatcher
and translating supervisor not-found responses into the SDK's sentinel
errors.

No server or task-runner loop is wired yet -- that lands in the next PR
in this stack.

Report URL: https://github.com/apache/airflow/actions/runs/26492720268

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to