medium10 pts · first answer countsairflowairflow-xcomairflow-templating

Pulling a named XCom in a template

Task extract pushed an XCom with key "row_count". Which template reads it inside a BashOperator command?

A.{{ xcom.extract.row_count }} from the contextB.{{ ti.xcom_pull(task_ids="extract", key="row_count") }}C.{{ params.row_count }} set by the extract taskD.{{ var.value.row_count }} from Variables

Discussion 0

Join free to post in the discussion.

Pulling a named XCom in a template

Discussion 0

Related questions