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