Answers for "xcom airflow"

0

xcom airflow

args = {
    'owner': '****',
    'start_date': airflow.utils.dates.days_ago(2),
    'provide_context': True
}
storage_objects = kwargs["ti"].xcom_pull(task_ids="list_files")
Posted by: Guest on November-16-2020
0

xcom airflow example

dag_1 = DAG('this_dag_will_be_discovered')

def my_function():
    dag_2 = DAG('but_this_dag_will_not')

my_function()
Posted by: Guest on August-04-2020

Browse Popular Code Answers by Language