编辑:我解决了我的问题。我不明白触发一个运行并立即运行和保持它运行并让它完成它的工作之间的区别。代码没问题。
我写了这个简单的程序来计算气流。在一个小时,它应该打印到一个文件"hello world",但它立即这样做。有没有人看到我哪里错了?
def print_hello():
f = open('helloword.txt','a')
f.write( 'Hello World!')
f.close()
dag = DAG('hello_world', description='Simple tutorial DAG', schedule_interval='@hourly',
start_date=datetime(2018, 5, 31), catchup=False)
hello_operator = PythonOperator(task_id='hello_task', python_callable=print_hello, dag=dag)
发布于 2018-06-01 04:24:05
你的代码在我看来没问题。如果您延迟DAG,您是否会看到一些附加到文件的行?
我想你看到的是回填执行。你把你的开始日期放在今天,隐含在午夜。因此,Airflow将赶上并首先启动这些DAG运行,然后最终每小时运行一次任务。
https://stackoverflow.com/questions/50631264
复制相似问题