Skip to content

Add xcom clearing behaviour on task retries#19968

Merged
potiuk merged 1 commit into
apache:mainfrom
kazanzhy:fix_issue_18917
Dec 5, 2021
Merged

Add xcom clearing behaviour on task retries#19968
potiuk merged 1 commit into
apache:mainfrom
kazanzhy:fix_issue_18917

Conversation

@kazanzhy

@kazanzhy kazanzhy commented Dec 2, 2021

Copy link
Copy Markdown
Contributor

Document task run behaviour according to the next lines

self._run_raw_task(

def _run_raw_task(

self._execute_task_with_callbacks(context)

def _execute_task_with_callbacks(self, context):

self.clear_xcom_data()

closes: #18917

@potiuk
potiuk merged commit 538612c into apache:main Dec 5, 2021
@kazanzhy
kazanzhy deleted the fix_issue_18917 branch December 6, 2021 10:29
@jedcunningham jedcunningham added this to the Airflow 2.2.3 milestone Dec 7, 2021
@jedcunningham jedcunningham added the type:doc-only Changelog: Doc Only label Dec 7, 2021
jedcunningham pushed a commit that referenced this pull request Dec 7, 2021
Co-authored-by: Dmytro Kazanzhy <dkazanzhy@demandbase.com>
(cherry picked from commit 538612c)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Document xcom clearing behaviour on task retries

3 participants