微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

气流不会在特定时间开始

如何解决气流不会在特定时间开始

我有一个 DAG,它的日程安排中有一个 cron 配置,但它总是在美国/危地马拉午夜开始,我分享了我的部分代码,我希望它在危地马拉上午 9 点开始,气流是作为aws服务,所以我没有很多驱动选项,谢谢你的支持,它是亚马逊云服务,这是utc中的配置,我只有美国/危地马拉时区的UI>

###code

from datetime import datetime,timedelta
import pendulum
import pytz
import time
from airflow import DAG
from airflow.operators.bash_operator import BashOperator

default_args = {
    'owner': 'David Martinez','depends_on_past': False,'retries': 0,'retry_delay': timedelta(minutes=5),'is_paused_upon_creation': False
    }   


dag=DAG(
        'test_excnt',description='JOB gluE',start_date=  datetime(2021,6,12,tzinfo=pendulum.timezone('America/Guatemala')),schedule_interval='0 9 * * *',default_args=default_args,max_active_runs=1,catchup=True)




t1 = BashOperator(
    task_id='1.1',bash_command="echo {{next_execution_date.in_timezone('America/Guatemala') }}",dag=dag
    # wait_for_downstream=True
    )

t2 = BashOperator(
    task_id='2',bash_command="echo {{execution_date.in_timezone('America/Guatemala') }}",dag=dag
    # wait_for_downstream=True
)

t1>>t2

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。