airflow #2

airflow 데이터 공유

​

xcom 대표적이다

내가 알기론 return 값 받아오는 것 안됨....

​

또 다른 방법으로

from airflow.models import Variable

​

처음에 Variable.set('crontab' , crontab)

interval = Variable.get("crontab", default_var='@hourly')

interval 값을 가져온다

​

global 변수처럼 사용할 수 있다

​

Xcom의 한계는 어디까지 일까?

제한된 크기가 궁금하다.