小编sio*_*owy的帖子

我如何检查何时为特定的dag计划了下一次Airflow DAG运行?

我已经设置了气流,并计划将某些DAG每天运行一次,设置为“ 0 0 * * *”。

我想检查什么时候下一次特定的dag计划运行,但是我看不到在管理员中可以执行的操作。

python scheduled-tasks airflow

4
推荐指数
2
解决办法
2066
查看次数

如何用两个'for'列举列表理解?

我想做

ls = [myfunc(a,b,i) for a in a_list for b in b_list]
Run Code Online (Sandbox Code Playgroud)

但也传入imyfunc,这是一个从0开始的索引,并为每个新元素递增.

例如:

a_list = 'abc'
b_list = 'def'
Run Code Online (Sandbox Code Playgroud)

应该导致

ls = [myfunc('a','d',0),
      myfunc('a','e',1),
      myfunc('a','f',2),
      myfunc('b','d',3),
      myfunc('b','e',4),
      ...
      myfunc('c','f',8]
Run Code Online (Sandbox Code Playgroud)

我知道我可以enumerate()用于正常情况,即.

ls = [myfunc(a,i) for a,i in enumerate(a_list)]
Run Code Online (Sandbox Code Playgroud)

但是,当有两个fors 时,我无法弄清楚如何干净利落地做到这一点.我以前找不到这个问题.

python list-comprehension enumerate

3
推荐指数
2
解决办法
317
查看次数