如何解决为单个手动气流创建多个DAG
每当我手动触发它时,就会看到触发了两个dag,我以为只会触发一个。
我不熟悉气流,所以不确定为什么会发生这种情况。
from airflow.operators import BashOperator
from datetime import datetime,timedelta
from pendulum import timezone
local_tz = timezone("Asia/dubai")
# Following are defaults which can be overridden later on
default_args = {
'owner': 'User','depends_on_past': False,'start_date': datetime(2016,4,15,tzinfo=local_tz)
}
dag = DAG('Helloworld',schedule_interval='0 17 * * *',default_args=default_args,catchup=False)
t1 = BashOperator(
task_id='task_1',bash_command='echo "Hello World from Task 1"',dag=dag)
t1
解决方法
通过编写schedule_interval = None只能运行一次,并且会看到这种行为,因为气流在24小时窗口内起作用,直到达到执行日期dag的24小时窗口都不会触发。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。