The GitHub Actions job "Tests" on airflow.git/asset-argument-wrapper has failed.
Run started by GitHub user uranusjr (triggered by uranusjr).

Head commit for run:
849f9c775ddc11ba9dbdcd0e7281b9dcffee76df / Tzu-ping Chung <[email protected]>
Allow pulling XCom from inlet events

This essentially adds a shorthand for doing XCom with ti information in
an asset event. Instead of doing

    event = context["inlet_events"][asset][-1]
    XCom.get_one(
        dag_id=event.source_dag_id,
        task_id=event.source_task_id,
        run_id=event.source_run_id,
        map_index=event.source_map_index,
    )

You can simply do

    context["inlet_events"][asset][-1].source_task_instance.xcom_pull()

This was already possible in 2.x since the event is an SQLAlchemy model
object, and can access the source_task_instance relationship. A simple
wrapper has been added so we can do the same inside the task runner.

Report URL: https://github.com/apache/airflow/actions/runs/14380048873

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to