[jira] [Comment Edited] (AIRFLOW-2072) Calling task from different DAG
[ https://issues.apache.org/jira/browse/AIRFLOW-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360412#comment-16360412 ] Yuliya Volkova edited comment on AIRFLOW-2072 at 2/12/18 8:15 AM: -- [~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 use i in import 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 was (Author: xnuinside): [~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 > 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)
[jira] [Comment Edited] (AIRFLOW-2072) Calling task from different DAG
[
https://issues.apache.org/jira/browse/AIRFLOW-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360412#comment-16360412
]
Yuliya Volkova edited comment on AIRFLOW-2072 at 2/12/18 8:14 AM:
--
[~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
was (Author: xnuinside):
[~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)
