airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yuliya Volkova (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AIRFLOW-2072) Calling task from different DAG
Date Mon, 12 Feb 2018 08:15:00 GMT

    [ https://issues.apache.org/jira/browse/AIRFLOW-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16360412#comment-16360412
] 

Yuliya Volkova commented on AIRFLOW-2072:
-----------------------------------------

[~AnilKumar2], hello!

What result do you want from this? Are you want just reuse code? If just reuse code - you
can do it like with any python code - move task to separate python function inside DAG .py
and import it from any place

or you want to get with task some results from it parent DAG?

If second variant - need to describe more information, but I think in Airflow there are things
like Xcom, if you need to share results.

Anyway if you will have more questions, join gitter - https://gitter.im/apache/incubator-airflow
there you can get answers more faster \{#emotions_dlg.smile}

 

> Calling task from different DAG
> -------------------------------
>
>                 Key: AIRFLOW-2072
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-2072
>             Project: Apache Airflow
>          Issue Type: Task
>          Components: Dataflow
>    Affects Versions: 1.9.0
>            Reporter: Anil Kumar
>            Priority: Major
>
> Hello Again,
> I am new for Airflow, started POC for ETL operation Orchestration activity using Airflow.
On creating new DAG, do we have any option to call existing task from other DAG to new one.
Like I want to call DAG_DataPrep.CopyEBCIDIC to new DAG.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message