diff --git a/apps/stocks/src/sensors.py b/apps/stocks/src/sensors.py index bfffb6d..4752619 100644 --- a/apps/stocks/src/sensors.py +++ b/apps/stocks/src/sensors.py @@ -35,7 +35,7 @@ def check_update(context: dg.SensorEvaluationContext) -> Iterator[dg.RunRequest] now_str = datetime.now().strftime("%Y-%m-%d %H:%M:%S") file = f"{now_str} stocks.html" context.log.info(f"Saving file: {file}") - with open(f"/cache/{file}") as fp: + with open(f"/cache/{file}", "w") as fp: fp.write(response.text) diff --git a/apps/vinyl/src/assets.py b/apps/vinyl/src/assets.py index b814693..cc9f43a 100644 --- a/apps/vinyl/src/assets.py +++ b/apps/vinyl/src/assets.py @@ -170,7 +170,9 @@ def works(context: dg.AssetExecutionContext) -> Iterator[dg.Output[pl.DataFrame] }, output_required=False, dagster_type=patito_model_to_dagster_type(Deal), - automation_condition=dg.AutomationCondition.eager(), + automation_condition=dg.AutomationCondition.on_missing().without( + dg.AutomationCondition.in_latest_time_window() + ), ) def new_deals( context: dg.AssetExecutionContext, partitions: dict[str, pl.LazyFrame | None]