TechQA.

Question

How can I access XCom values in traditional operator that were defined in TaskFlow function?

score 33 · Answer 1 · 2024-03-21T18:23:52.137000

0

Answer

33

Views

How can I access XCom values in traditional operator that were defined in TaskFlow function?

33 views Asked by user2715877 At 21 March 2024 at 18:23

score 36 · Answer 2 · 2024-03-15T01:51:38.863000

Fetching data from API takes longer time to run because the data is large

36 views Asked by Anamsken At 15 March 2024 at 01:51

score 12 · Answer 3 · 2024-03-14T10:13:14.050000

Is there an airflow trigger rule for only success or failure or skipped? (i.e. run if anything except upstream_failure detected)

12 views Asked by kahhengchong At 14 March 2024 at 10:13

score 55 · Answer 4 · 2024-03-09T02:27:23.050000

"ValueError: non-default argument follows default argument" when upgrading from Airflow 2.2.2 to 2.8.1

55 views Asked by Kevin Languasco At 09 March 2024 at 02:27

score 41 · Answer 5 · 2024-03-07T13:17:30.860000

Airflow branching: A task that only sometimes depends on an upstream task

41 views Asked by dwolfeu At 07 March 2024 at 13:17

score 20 · Answer 6 · 2024-03-04T14:53:43.437000

How can a task running twice per day depend on one task running once per day in airflow?

20 views Asked by flyaga At 04 March 2024 at 14:53

score 62 · Answer 7 · 2024-02-29T17:59:17.577000

Airflow : Complete all tasks in a TaskGroup before running to the next one and avoid dependancies between TaskGroup

62 views Asked by Antoine F At 29 February 2024 at 17:59

score 115 · Answer 8 · 2024-02-28T13:20:24.130000

Override TaskGroup in Airflow

115 views Asked by Alex At 28 February 2024 at 13:20

score 151 · Answer 9 · 2024-02-27T16:45:32.040000

TypeError: 'XComArg' object is not iterable on task.group and DAG level but not on external tasks?

151 views Asked by neverMind At 27 February 2024 at 16:45

score 36 · Answer 10 · 2024-02-22T13:19:42.110000

Airflow DAG starts duplicate when execution is slow

36 views Asked by owfgktalef At 22 February 2024 at 13:19

score 26 · Answer 11 · 2024-02-22T05:58:23.873000

In Airflow Pool Dagrun status is scheduled but in List Dag Run Dagrun status is running

26 views Asked by Ashwani Singh At 22 February 2024 at 05:58

score 229 · Answer 12 · 2024-02-20T07:36:34.550000

How to enable test connection button in Airflow in v2.7.1

229 views Asked by Swati Ojha At 20 February 2024 at 07:36

score 52 · Answer 13 · 2024-02-19T15:07:29.463000

Airflow : Task wise dependency check with another Dag using ExternalTaskSensor

52 views Asked by Sachin Sukumaran At 19 February 2024 at 15:07

score 56 · Answer 14 · 2024-02-15T06:30:17.033000

The Apache Airflow DAG executed successfully, yet it continues to appear as active in the Flower UI and remains in memory

56 views Asked by Sagar Bhatt At 15 February 2024 at 06:30

score 52 · Answer 15 · 2024-01-31T14:30:56.450000

Airflow - Sequential Dynamic taskgroups

52 views Asked by Manuel G At 31 January 2024 at 14:30

score 36 · Answer 16 · 2024-01-30T16:20:49.027000

Is there a way to retrieve latest success dag run intervals without considering dags with skipped tasks?

36 views Asked by vian At 30 January 2024 at 16:20

score 19 · Answer 17 · 2024-01-22T16:14:06.060000

Airflow - Is there a way to set a timeout for a job to be based on yesterday's run?

19 views Asked by AkashJain At 22 January 2024 at 16:14

score 36 · Answer 18 · 2024-01-12T00:45:21.827000

accessing Xcom value inside taskgroup astronomer

36 views Asked by gayathri At 12 January 2024 at 00:45

score 79 · Answer 19 · 2024-01-11T15:48:38.470000

Airflow v2 Create Dynamic Task Mapping based on input config from UI

79 views Asked by bcsta At 11 January 2024 at 15:48

score 54 · Answer 20 · 2024-01-09T19:40:48.193000

Airflow: EMR step sensor to wait for individual job when steps are submitted in parallel and submit another set of EMR steps after each job completes

TechQA.

List Question

How can I access XCom values in traditional operator that were defined in TaskFlow function?

Fetching data from API takes longer time to run because the data is large

Is there an airflow trigger rule for only success or failure or skipped? (i.e. run if anything except upstream_failure detected)

"ValueError: non-default argument follows default argument" when upgrading from Airflow 2.2.2 to 2.8.1

Airflow branching: A task that only sometimes depends on an upstream task

How can a task running twice per day depend on one task running once per day in airflow?

Airflow : Complete all tasks in a TaskGroup before running to the next one and avoid dependancies between TaskGroup

Override TaskGroup in Airflow

TypeError: 'XComArg' object is not iterable on task.group and DAG level but not on external tasks?

Airflow DAG starts duplicate when execution is slow

In Airflow Pool Dagrun status is scheduled but in List Dag Run Dagrun status is running

How to enable test connection button in Airflow in v2.7.1

Airflow : Task wise dependency check with another Dag using ExternalTaskSensor

The Apache Airflow DAG executed successfully, yet it continues to appear as active in the Flower UI and remains in memory

Airflow - Sequential Dynamic taskgroups

Is there a way to retrieve latest success dag run intervals without considering dags with skipped tasks?

Airflow - Is there a way to set a timeout for a job to be based on yesterday's run?

accessing Xcom value inside taskgroup astronomer

Airflow v2 Create Dynamic Task Mapping based on input config from UI

Airflow: EMR step sensor to wait for individual job when steps are submitted in parallel and submit another set of EMR steps after each job completes

Popular Questions

Trending Questions