jason810496 opened a new pull request, #70158:
URL: https://github.com/apache/airflow/pull/70158
- Depends on: the `refactor/go-sdk/dag-authoring-api` PR (this branch is
stacked on it; only the tip commit is new here).
-
## Why
The Go SDK's dag-authoring API wired dependencies with string task ids
(`AddTask(fn, spec, []string{"extract"})`), which is typo-prone, forces
upstream-first registration, and carries no data — downstream tasks had to pull
upstream results from XCom by hand. Python's TaskFlow shows the better model:
dependencies fall out of data flow. This PR brings that model to Go.
```go
d := reg.AddDag(v1.DagSpec{DagId: "etl", Schedule: "@daily"})
extracted := d.Task(extract) //
(ExtractResult, error)
transformed := d.Task(transform, v1.Inputs(extracted)) // receives
ExtractResult
d.Task(load, v1.Inputs(transformed), v1.TaskSpec{Retries: 2}) // receives
TransformResult
```
---
##### Was generative AI tooling used to co-author this PR?
- [x] Yes, with help of Claude Code (Fable 5) following [the
guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
