jason810496 commented on PR #74391:
URL: https://github.com/apache/airflow/pull/74391#issuecomment-6034845514
Pushed a few follow-up commits on top:
- Dropped the task-sdk and core stderr-excerpt changes, so this PR is Go SDK
only. They can go in a separate PR if needed.
- Removed `bundle.Registry`. `execution.Serve` takes `bundle.Bundle` again
and checks for `bundle.DagSerializer` in the parse branch. The adapter is now
`coordinatorSource{*taskHandlerMap; dags *dagMap}`, the same shape as
`manifestSource` in #74342.
- The parse result now replies on the request id and exits, the same as the
TS runtime and ADR 0003. The ack wait and its test are removed.
- `parseDags` returns an empty result when the bundle has no Dags, and logs
`Received Dag parse request` / `Parse-mode response` at info, the same as TS.
- `serializeRecovering` now logs the panic stack.
- Trimmed the comments added in this PR.
- Native Dag task lookup in `LookupTask` will be fixed in #74342.
--
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]
