1

我读了这个问题,我可以使用以下命令成功运行DAGairflow backfill -s -1 pipeline,但它是手动执行的。我想知道如何在特定的时间间隔内自动执行我的 dags。我是新手,但我仍然卡住了。我也阅读了本指南,但显然作者Celery用来执行 dags 并且我有一些关于它的问题,例如,当我尝试运行airflow worker它时说我使用了一个端口,我可以通过降级来解决它,Celery正如他们所说的这里。然而,当我再次尝试运行它时,我得到了更多的错误。

请注意,当我定义 my 时DAG,我尝试每 2 分钟运行一次。

dag = DAG(dag_id='pipeline',
          default_args=args,
          schedule_interval='*/2 * * * *',
          dagrun_timeout=timedelta(seconds=30))
4

0 回答 0