diff --git a/apps/vinyl/src/assets.py b/apps/vinyl/src/assets.py index 8f26651..9c0bc0d 100644 --- a/apps/vinyl/src/assets.py +++ b/apps/vinyl/src/assets.py @@ -172,7 +172,7 @@ def works(context: dg.AssetExecutionContext) -> Iterator[dg.Output[pl.DataFrame] dagster_type=patito_model_to_dagster_type(Deal), automation_condition=dg.AutomationCondition.on_missing().ignore( dg.AssetSelection.assets(cleaned_deals.key) - ) + ), ) def new_deals( context: dg.AssetExecutionContext, partitions: dict[str, pl.LazyFrame | None]