Skip to content

Commit 6de2c86

Browse files
committed
add METOFFICE_DELAY_MINUTES
1 parent 70596b1 commit 6de2c86

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

src/nwp_consumer/internal/entities/modelmetadata.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -197,10 +197,6 @@ def with_chunk_count_overrides(self, overrides: dict[str, int]) -> "ModelMetadat
197197
)
198198
return dataclasses.replace(self, chunk_count_overrides=overrides)
199199

200-
def with_delay_minutes(self, minutes: int) -> "ModelMetadata":
201-
"""Returns metadata for the given model with the given delay minutes."""
202-
return dataclasses.replace(self, delay_minutes=minutes)
203-
204200
def with_running_hours(self, hours: list[int]) -> "ModelMetadata":
205201
"""Returns metadata for the given model with the given running hours."""
206202
return dataclasses.replace(self, running_hours=hours)

src/nwp_consumer/internal/repositories/raw_repositories/mo_datahub.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ def repository() -> entities.RawRepositoryMetadata:
156156
name="MetOffice-Weather-Datahub",
157157
is_archive=False,
158158
is_order_based=True,
159-
delay_minutes=60*5,
159+
delay_minutes=int(os.getenv("METOFFICE_DELAY_MINUTES", 120)),
160160
max_connections=10,
161161
required_env=["METOFFICE_API_KEY", "METOFFICE_ORDER_ID"],
162162
optional_env={"METOFFICE_DATASPEC": "1.1.0"},
@@ -165,7 +165,7 @@ def repository() -> entities.RawRepositoryMetadata:
165165
"default": entities.Models.MO_UM_GLOBAL_10KM.with_region("india"),
166166
"um-global-10km-india": entities.Models.MO_UM_GLOBAL_10KM.with_region("india"),
167167
"um-global-10km-uk": entities.Models.MO_UM_GLOBAL_10KM.with_region("uk"),
168-
"um-ukv-2km": entities.Models.MO_UM_UKV_2KM_LAEA.with_delay_minutes(120),
168+
"um-ukv-2km": entities.Models.MO_UM_UKV_2KM_LAEA,
169169
},
170170
)
171171

0 commit comments

Comments
 (0)