Merge pull request #387 from hydroserver2/386-etl-internal-loader-window-calc

kjlippold · web-flow · commit 9e4f406b9d66 · 2026-03-26T10:15:31.000-07:00
Fixed ETL loader window calculation.
diff --git a/django/domains/etl/internal.py b/django/domains/etl/internal.py
@@ -149,7 +149,7 @@ def load(
                 f"Missing datastream IDs: {', '.join(sorted(missing_datastreams))}."
             )
 
-        if any(datastream.phenomenon_end_time is None for datastream in datastreams.values()):
+        if not datastreams or any(datastream.phenomenon_end_time is None for datastream in datastreams.values()):
             earliest_phenomenon_end_time = None
         else:
             earliest_phenomenon_end_time = min(

Original file line number	Diff line number	Diff line change
`@@ -149,7 +149,7 @@ def load(`
`149`	`149`	`f"Missing datastream IDs: {', '.join(sorted(missing_datastreams))}."`
`150`	`150`	`)`
`151`	`151`
`152`		`- if any(datastream.phenomenon_end_time is None for datastream in datastreams.values()):`
	`152`	`+ if not datastreams or any(datastream.phenomenon_end_time is None for datastream in datastreams.values()):`
`153`	`153`	`earliest_phenomenon_end_time = None`
`154`	`154`	`else:`
`155`	`155`	`earliest_phenomenon_end_time = min(`