adjust automation condition
This commit is contained in:
@@ -232,7 +232,7 @@ def new_deals(
|
||||
},
|
||||
ins={"partitions": dg.AssetIn(key=new_deals.key)},
|
||||
output_required=False,
|
||||
automation_condition=dg.AutomationCondition.eager(),
|
||||
automation_condition=dg.AutomationCondition.eager().without(~dg.AutomationCondition.any_deps_missing())
|
||||
)
|
||||
def good_deals(
|
||||
context: dg.AssetExecutionContext,
|
||||
|
||||
Reference in New Issue
Block a user