我已经设置了气流,并计划将某些DAG每天运行一次,设置为“ 0 0 * * *”。
我想检查什么时候下一次特定的dag计划运行,但是我看不到在管理员中可以执行的操作。
我想做
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 时,我无法弄清楚如何干净利落地做到这一点.我以前找不到这个问题.