Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Handle clearing XCom in run Execution endpoint #45419

Closed
kaxil opened this issue Jan 6, 2025 · 0 comments · Fixed by #45506
Closed

Handle clearing XCom in run Execution endpoint #45419

kaxil opened this issue Jan 6, 2025 · 0 comments · Fixed by #45506
Assignees
Labels
area:API Airflow's REST/HTTP API

Comments

@kaxil
Copy link
Member

kaxil commented Jan 6, 2025

We should clear XCom value when task starts execution in the Execution API server. This is how it is done now:

# Don't clear Xcom until the task is certain to execute, and check if we are resuming from deferral.
if not self.next_method:
self.clear_xcom_data()

Ideally, this can be done in the run endpoint. We need to ensure we don't clear it for Deferrable tasks.

Port the necessary tests from current execution model to the API server

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area:API Airflow's REST/HTTP API
Development

Successfully merging a pull request may close this issue.

2 participants