[GH] (airflow/add-callback-source-to-context): Workflow run "Tests" failed!
The GitHub Actions job "Tests" on airflow.git/add-callback-source-to-context
has failed.
Run started by GitHub user vasanthrpjan1-boop (triggered by potiuk).
Head commit for run:
191d48c2705907de9ca38efe050399bc9db4c194 / vasanthrpjan1-boop
Add callback_source to context to differentiate DAG vs task callbacks
Currently a callback defined at the DAG level receives a context that
is nearly identical to a task-level callback context, making it
impossible to tell which level triggered the call.
This adds a `CallbackSource` enum ("dag" / "task") and a `CallbackMeta`
named tuple, and injects `context["callback"] = CallbackMeta(source=...)`
in every code path that invokes callbacks:
- task_runner._run_task_state_change_callbacks (in-worker task path)
- processor._execute_dag_callbacks (DAG processor path)
- processor._execute_task_callbacks (DAG processor path)
- DagRun.handle_dag_callback(dag.test() path)
Both `CallbackSource` and `CallbackMeta` are exported from `airflow.sdk`.
Closes: #61119
Made-with: Cursor
Report URL: https://github.com/apache/airflow/actions/runs/25201160400
With regards,
GitHub Actions via GitBox
-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
[GH] (airflow/add-callback-source-to-context): Workflow run "Tests" failed!
The GitHub Actions job "Tests" on airflow.git/add-callback-source-to-context
has failed.
Run started by GitHub user vasanthrpjan1-boop (triggered by kaxil).
Head commit for run:
191d48c2705907de9ca38efe050399bc9db4c194 / vasanthrpjan1-boop
Add callback_source to context to differentiate DAG vs task callbacks
Currently a callback defined at the DAG level receives a context that
is nearly identical to a task-level callback context, making it
impossible to tell which level triggered the call.
This adds a `CallbackSource` enum ("dag" / "task") and a `CallbackMeta`
named tuple, and injects `context["callback"] = CallbackMeta(source=...)`
in every code path that invokes callbacks:
- task_runner._run_task_state_change_callbacks (in-worker task path)
- processor._execute_dag_callbacks (DAG processor path)
- processor._execute_task_callbacks (DAG processor path)
- DagRun.handle_dag_callback(dag.test() path)
Both `CallbackSource` and `CallbackMeta` are exported from `airflow.sdk`.
Closes: #61119
Made-with: Cursor
Report URL: https://github.com/apache/airflow/actions/runs/25201160400
With regards,
GitHub Actions via GitBox
-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
[GH] (airflow/add-callback-source-to-context): Workflow run "Tests" failed!
The GitHub Actions job "Tests" on airflow.git/add-callback-source-to-context has failed. Run started by GitHub user vasanthrpjan1-boop (triggered by potiuk). Head commit for run: e5a34223f73ee00f74639beaec1006d912c8654b / vasanthrpjan1-boop Add CallbackMeta and CallbackSource to __all__ in airflow.sdk The test_lazy_imports_match_public_api test requires all entries in __lazy_imports to also be present in __all__. Made-with: Cursor Report URL: https://github.com/apache/airflow/actions/runs/23950090648 With regards, GitHub Actions via GitBox - To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
[GH] (airflow/add-callback-source-to-context): Workflow run "Tests" failed!
The GitHub Actions job "Tests" on airflow.git/add-callback-source-to-context
has failed.
Run started by GitHub user vasanthrpjan1-boop (triggered by potiuk).
Head commit for run:
7f05f97ee0573c07e12c2046eb5dd1016550720a / vasanthrpjan1-boop
Add callback_source to context to differentiate DAG vs task callbacks
Currently a callback defined at the DAG level receives a context that
is nearly identical to a task-level callback context, making it
impossible to tell which level triggered the call.
This adds a `CallbackSource` enum ("dag" / "task") and injects it as
`context["callback_source"]` in every code path that invokes callbacks:
- task_runner._run_task_state_change_callbacks (in-worker task path)
- processor._execute_dag_callbacks (DAG processor path)
- processor._execute_task_callbacks (DAG processor path)
- DagRun.handle_dag_callback(dag.test() path)
Closes: #61119
Co-authored-by: Cursor
Report URL: https://github.com/apache/airflow/actions/runs/23575264951
With regards,
GitHub Actions via GitBox
-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
[GH] (airflow/add-callback-source-to-context): Workflow run "Tests" failed!
The GitHub Actions job "Tests" on airflow.git/add-callback-source-to-context
has failed.
Run started by GitHub user vasanthrpjan1-boop (triggered by potiuk).
Head commit for run:
26b49f70ebf89d367ec18273c10e030c5bace0f5 / vasanthrpjan1-boop
Add callback_source to context to differentiate DAG vs task callbacks
Currently a callback defined at the DAG level receives a context that
is nearly identical to a task-level callback context, making it
impossible to tell which level triggered the call.
This adds a `CallbackSource` enum ("dag" / "task") and injects it as
`context["callback_source"]` in every code path that invokes callbacks:
- task_runner._run_task_state_change_callbacks (in-worker task path)
- processor._execute_dag_callbacks (DAG processor path)
- processor._execute_task_callbacks (DAG processor path)
- DagRun.handle_dag_callback(dag.test() path)
Closes: #61119
Co-authored-by: Cursor
Report URL: https://github.com/apache/airflow/actions/runs/22992259748
With regards,
GitHub Actions via GitBox
-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
