气流不会在特定时间开始

编程问答 2022-04-23

问题描述

我有一个 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 (将#修改为@）

airflowairflowcroncronschedulescheduletimezonetimezone