The GitHub Actions job "Tests (AMD)" on 
airflow.git/refactor/go-sdk/inject-ti-run-context-at-argument-level has 
succeeded.
Run started by GitHub user jason810496 (triggered by jason810496).

Head commit for run:
3c678a0b314b9ecc96a400370b488518046df07c / LIU ZHE YOU <[email protected]>
Go-SDK: Inject task runtime context as sdk.TIRunContext parameter

Replace the sdk.CurrentContext(ctx) accessor and sdk.RuntimeContext type
with sdk.TIRunContext, which embeds context.Context and carries the task
instance identifiers and Dag run scheduling timestamps. Task authors now
declare it as the task's context parameter and the runtime binds it by
type, so they no longer pass a context to a function to get a context:

    func extract(ctx sdk.TIRunContext, log *slog.Logger) (any, error) {
        log.Info("run", "task_id", ctx.TI.TaskID, "run_id", ctx.DagRun.RunID)
    }

Because TIRunContext is itself a context.Context, it flows straight into
client calls, ctx.Done(), and downstream helpers. Plain context.Context
binding is retained for the Edge Worker path, which does not yet populate
the runtime context.

Report URL: https://github.com/apache/airflow/actions/runs/27293018404

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to