擅长:python、mysql、java
<p>我找到了
<code>schedule=@once</code>对我的子表来说很好。也许我的版本已经过时了,但是我的子任务失败的问题比相反的要多。在</p>
<p>现在在我的机器上运行得非常愉快的实际示例代码:</p>
<pre><code>subdag_name = ".".join((parent_name,child_name))
logging.info(parent_name)
logging.info(subdag_name)
dag_subdag = DAG(
dag_id=subdag_name,
default_args=dargs,
schedule_interval="@once",
)
</code></pre>
<p>事实上,我最初几乎把所有的dag都构建为子dag的美化cfg文件。我不知道经过一番尝试和错误后的想法有多好,但时间间隔对我来说从来都不是阻碍。在</p>
<p>我运行的是一个相对较新的1.8版本,几乎没有定制。我一直在遵循示例dag的建议,即将我的子dag保存在dags文件夹中的一个文件夹中,这样它们就不会出现在DagBag中。在</p>