在Snowflake任务中,我们是否有类似子任务的任务会等到满足依赖关系后再执行父任务条件

问题描述

我有4个流。 A_STREAM,B_STREAM,C_STREAM,D_ STREAM

我有一个任务链,其中A_TASK是父任务,它有3个子任务(B_TASK,C_TASK,D_TASK)。

CREATE TASK A_TASK
WAREHOUSE = XYZ
SECHDULE = '15 MINUTE'
WHEN SYstem$STREAM_HAS_DATA('A_STREAM)
AS 
DO Something;
CREATE TASK C_TASK
WAREHOUSE=XYZ
AFTER A_TASK
WHEN SYstem$STREAM_HAS_DATA('C_STREAM')
AS 
DO SOMETHING;

假设A_TASK已触发并完成,但在执行C_TASK流时,C_STREAM没有数据,因此任务也未触发。 5分钟后,C_STREAM获得了数据。

这里的问题是,因为下次不会触发A_TASK,所以数据永远不会从C_STREAM加载到目标表。我们如何解决这种秘密?

我不能分开这些任务,因为它们在同一目标表上运行。

在SNowflake任务中,我们是否有类似子任务之类的东西会等到满足依赖性为止?

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)