Skip to content
Discussion options

You must be logged in to vote

@O-Carneiro the right way would be to use XCom.delete function.

Example:

def delete_xcom():
    from airflow.sdk.execution_time.xcom import XCom
    XCom.delete(
        key="return_value",
        task_id="test_task",
        dag_id="test_dag_from_modesl",
        run_id="scheduled__2025-05-10T00:00:00+00:00",
    )

Replies: 1 comment

Comment options

You must be logged in to vote
0 replies
Answer selected by amoghrajesh
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Category
Q&A
Labels
None yet
2 participants