Skip to content

Implement on_execute_callback in task sdk#47989

Merged
uranusjr merged 1 commit into
apache:mainfrom
astronomer:task-sdk-on-execute-callback
Mar 20, 2025
Merged

Implement on_execute_callback in task sdk#47989
uranusjr merged 1 commit into
apache:mainfrom
astronomer:task-sdk-on-execute-callback

Conversation

@uranusjr

Copy link
Copy Markdown
Member

The callable is run outside of the timeout block. Failures calling any callback functions are simply logged without failing the entire task. This matches Airflow 2's behavior.

Submitting this first to get feedback. Other callbacks will be implemented in later PRs if I'm on the right track.

First part of #45424.

@uranusjr uranusjr added area:task-execution-interface-aip72 AIP-72: Task Execution Interface (TEI) aka Task SDK area:task-sdk and removed area:task-sdk labels Mar 20, 2025
@uranusjr
uranusjr force-pushed the task-sdk-on-execute-callback branch from 5c44871 to fca51b4 Compare March 20, 2025 09:46
Comment thread task-sdk/tests/task_sdk/execution_time/test_task_runner.py Outdated
Comment thread task-sdk/tests/task_sdk/execution_time/test_task_runner.py Outdated
The callable is run *outside* of the timeout block. Failures calling
any callback functions are simply logged without failing the entire
task. This matches Airflow 2's behavior.

Submitting this first to get feedback. Other callbacks will be
implemented in later PRs if I'm on the right track.
@uranusjr
uranusjr force-pushed the task-sdk-on-execute-callback branch from fca51b4 to b6d5536 Compare March 20, 2025 10:23
@uranusjr
uranusjr merged commit 490bb57 into apache:main Mar 20, 2025
@uranusjr
uranusjr deleted the task-sdk-on-execute-callback branch March 20, 2025 11:22
agupta01 pushed a commit to agupta01/airflow that referenced this pull request Mar 21, 2025
The callable is run *outside* of the timeout block. Failures calling
any callback functions are simply logged without failing the entire
task. This matches Airflow 2's behavior.

Submitting this first to get feedback. Other callbacks will be
implemented in later PRs if I'm on the right track.
shubham-pyc pushed a commit to shubham-pyc/airflow that referenced this pull request Mar 22, 2025
The callable is run *outside* of the timeout block. Failures calling
any callback functions are simply logged without failing the entire
task. This matches Airflow 2's behavior.

Submitting this first to get feedback. Other callbacks will be
implemented in later PRs if I'm on the right track.
nailo2c pushed a commit to nailo2c/airflow that referenced this pull request Apr 4, 2025
The callable is run *outside* of the timeout block. Failures calling
any callback functions are simply logged without failing the entire
task. This matches Airflow 2's behavior.

Submitting this first to get feedback. Other callbacks will be
implemented in later PRs if I'm on the right track.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

area:task-execution-interface-aip72 AIP-72: Task Execution Interface (TEI) aka Task SDK area:task-sdk

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants