我正在使用GenerateTableFetch
包含table_name
导入数据的传入流文件。我已经手动使用表的列Additional WHERE clause
来处理增量更新。updated_at
问题是当构建查询没有要导入的数据时,它只是删除流文件。对于这种情况,除了成功和失败之外,它应该有一个单独的关系,这样如果必须为这种情况做些什么,我可以自己处理。
目前,在工作流程开始时,我正在使用Wait
已投入流程的表格数量并跟踪它们何时完成以使用Notify
. 但是对于被丢弃的表GenerateTableFetch
,它只是继续等待。
有什么办法处理这个吗?