From b26ba7aa35fd16a3580e31f93d981d64d6b2b93a Mon Sep 17 00:00:00 2001
From: Rik Veenboer <rik.veenboer@gmail.com>
Date: Mon, 4 Aug 2025 19:09:32 +0200
Subject: [PATCH] tweaks

---
 apps/stocks/src/sensors.py | 2 +-
 apps/vinyl/src/assets.py   | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

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]