diff --git a/ocf_datapipes/config/model.py b/ocf_datapipes/config/model.py index a0d394d08..69a995a54 100644 --- a/ocf_datapipes/config/model.py +++ b/ocf_datapipes/config/model.py @@ -287,6 +287,7 @@ class Wind(DataSourceMixin, TimeResolutionMixin, XYDimensionalNames, DropoutMixi @field_validator("forecast_minutes") def forecast_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo) -> int: + """Check forecast length requested will give stable number of timesteps""" if v % info.data["time_resolution_minutes"] != 0: message = "Forecast duration must be divisible by time resolution" logger.error(message) @@ -295,6 +296,7 @@ def forecast_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo @field_validator("history_minutes") def history_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo) -> int: + """Check history length requested will give stable number of timesteps""" if v % info.data["time_resolution_minutes"] != 0: message = "History duration must be divisible by time resolution" logger.error(message) @@ -402,6 +404,7 @@ def model_validation(cls, v): @field_validator("forecast_minutes") def forecast_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo) -> int: + """Check forecast length requested will give stable number of timesteps""" if v % info.data["time_resolution_minutes"] != 0: message = "Forecast duration must be divisible by time resolution" logger.error(message) @@ -410,6 +413,7 @@ def forecast_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo @field_validator("history_minutes") def history_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo) -> int: + """Check history length requested will give stable number of timesteps""" if v % info.data["time_resolution_minutes"] != 0: message = "History duration must be divisible by time resolution" logger.error(message) @@ -641,6 +645,7 @@ def validate_nwp_provider(cls, v: str) -> str: @field_validator("forecast_minutes") def forecast_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo) -> int: + """Check forecast length requested will give stable number of timesteps""" if v % info.data["time_resolution_minutes"] != 0: message = "Forecast duration must be divisible by time resolution" logger.error(message) @@ -649,6 +654,7 @@ def forecast_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo @field_validator("history_minutes") def history_minutes_divide_by_time_resolution(cls, v: int, info: ValidationInfo) -> int: + """Check history length requested will give stable number of timesteps""" if v % info.data["time_resolution_minutes"] != 0: message = "History duration must be divisible by time resolution" logger.error(message)