-
Notifications
You must be signed in to change notification settings - Fork 17.1k
Refactor ExecutableCoordinator interface based on dev-list design discussion #66936
Copy link
Copy link
Open
Labels
area:providersgo-sdkLabel to track work items for golang task sdkLabel to track work items for golang task sdkkind:featureFeature RequestsFeature Requestskind:taskA task that needs to be completed as part of a larger issueA task that needs to be completed as part of a larger issueon holdpriority:highHigh priority bug that should be patched quickly but does not require immediate new releaseHigh priority bug that should be patched quickly but does not require immediate new release
Metadata
Metadata
Assignees
Labels
area:providersgo-sdkLabel to track work items for golang task sdkLabel to track work items for golang task sdkkind:featureFeature RequestsFeature Requestskind:taskA task that needs to be completed as part of a larger issueA task that needs to be completed as part of a larger issueon holdpriority:highHigh priority bug that should be patched quickly but does not require immediate new releaseHigh priority bug that should be patched quickly but does not require immediate new release
Type
Fields
Give feedbackNo fields configured for issues without a type.
Projects
Status
No status
Background
The current
ExecutableCoordinator(
providers/sdk/executable/src/airflow/providers/sdk/executable/coordinator.py)is the shared Python-side launcher for any native-executable SDK (Go, Rust,
C++, Zig, ...) that produces an
AFBNDL01-trailered bundle. It currentlyexposes
can_handle_dag_file,get_code_from_file,dag_parsing_cmd,and
task_execution_cmdand handles both the pure-executable Dag pathand the Python
@task.stubDag path.A design discussion is in flight on the dev list about how this interface
should evolve as more lang-SDKs adopt it. The decision is not yet final;
this issue exists to track the eventual refactor so the deferred work has
a stable URL.
What needs to happen
ExecutableCoordinator.providers/sdk/executable/docs/bundle-spec.rst)to match.
bundlev1server.Servecoordinator-mode dispatcher(ADR 0003) only if the interface change requires a wire-level adjustment.
the same time.
Acceptance criteria
ExecutableCoordinatorinterface matches the dev-list outcome.go-sdk/adr/are updated to reflect the new shape.Context
BaseCoordinatorinterface to support pluggable communication channels #66838 (pluggable BaseCoordinator).8612c4574f2("Fix commandresolution in ExecutableCoordinator for improved task execution").
Drafted-by: Claude Code (Opus 4.7) (no human review before posting)