Skip to content

Dag and task-level callbacks in the Go SDK #66944

Description

@jason810496

Background

on_success_callback / on_failure_callback / on_retry_callback /
Dag-level on_*_callback are not addressable from a Go task today.
The Java side is tracking the same gap under #66543. Probably blocked
on a cross-language design decision (do we call back into Python, or
do we invoke a separately-registered Go function via the coordinator
protocol?).

What needs to happen

  1. Decide the callback shape jointly with the Java tracking issue
    (Java-based task and dag level callbacks #66543) - probably a new coordinator-protocol message type.
  2. Surface the registration on the Go side via bundlev1.TaskSpec /
    DagSpec.
  3. Serialise the callback identity into the Dag JSON so the supervisor
    knows which Go function to dispatch back to.

Acceptance criteria

Context


Drafted-by: Claude Code (Opus 4.7) (no human review before posting)

Metadata

Metadata

Assignees

Labels

area:corego-sdkLabel to track work items for golang task sdkkind:featureFeature Requestspriority:lowBug with a simple workaround that would not block a release

Type

No type

Fields

No fields configured for issues without a type.

Projects

Status
No status

Relationships

None yet

Development

No branches or pull requests

Issue actions