The GitHub Actions job "Tests (AMD)" on airflow.git/feature/go-sdk/taskflow-syntax has failed. Run started by GitHub user jason810496 (triggered by jason810496).
Head commit for run: 0ea0905727a9031493fdeda7176a03da0a91e25a / LIU ZHE YOU <[email protected]> Go-SDK: TaskFlow-style dag authoring with XCom-injected task inputs Dag.Task(fn, opts...) replaces AddTask/AddTaskWithName and returns a *TaskRef handle. Passing handles via v1.Inputs(...) wires the dependency edge and feeds each upstream's return value into the matching data parameter of the task function at run time: the runtime pulls the upstream's return-value XCom and strictly decodes it into the declared parameter type, so a Go dag reads like plain function composition: d := reg.AddDag(v1.DagSpec{DagId: "etl", Schedule: "@daily"}) extracted := d.Task(extract) d.Task(transform, v1.Inputs(extracted)) v1.After(...) declares ordering-only edges. Task ids move into the specs: TaskSpec.TaskId (generated from schema.json as an identity field) and DagSpec.DagId replace positional ids and AddTaskWithName. Mismatched input counts or types, refs from another dag, and non-decodable parameters all panic at registration, i.e. dag-parse time. Binding is shared by the coordinator and Edge worker paths. Report URL: https://github.com/apache/airflow/actions/runs/29809817676 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
