[Airflow] Xcom에 데이터 남기지 않는 방법

기존 DAG - Xcom에 데이터를 task마다 남긴다..

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime

dag = DAG (
	dag_id = '2_python_operator',
	start_date = datetime(2022, 12, 3),
	schedule_interval = '* * * * *',
	catchup = False,
	tags = ['server_local', 'detail_test'],
	description = 'Python Operator Sample',
	default_args = {'owner': 'ParkGyeongTae'})

def func_print_1():
	return '1'

task_print_1 = PythonOperator(task_id = 'print_1', python_callable = func_print_1, dag = dag)

task_print_1

 

신규 DAG - 이제는 Xcom에 데이터를 남기지 않는다

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from datetime import datetime

dag = DAG (
	dag_id = '2_python_operator',
	start_date = datetime(2022, 12, 3),
	schedule_interval = '* * * * *',
	catchup = False,
	tags = ['server_local', 'detail_test'],
	description = 'Python Operator Sample',
	default_args = {'owner': 'ParkGyeongTae'})

def func_print_1():
	return '1'

task_print_1 = PythonOperator(task_id = 'print_1', python_callable = func_print_1, dag = dag, do_xcom_push = False)

task_print_1