我的气流DAG和操作员没有按照我的预期进行操作
我的气流DAG和操作员没有按照我的预期进行操作
提问于 2018-06-01 03:11:55
编辑:我解决了我的问题。我不明白触发一个运行并立即运行和保持它运行并让它完成它的工作之间的区别。代码没问题。
我写了这个简单的程序来计算气流。在一个小时，它应该打印到一个文件"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)回答 1
Stack Overflow用户
发布于 2018-06-01 04:24:05
你的代码在我看来没问题。如果您延迟DAG，您是否会看到一些附加到文件的行？
我想你看到的是回填执行。你把你的开始日期放在今天，隐含在午夜。因此，Airflow将赶上并首先启动这些DAG运行，然后最终每小时运行一次任务。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/50631264
复制相关文章
相似问题