From b9c7ef2db57d860910de3f3ce92489f0dd427f4a Mon Sep 17 00:00:00 2001 From: devsjc Date: Mon, 2 Oct 2023 17:15:04 +0100 Subject: [PATCH] Enable backdating of ECMWF data to 2020 --- nwp/jobs.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/nwp/jobs.py b/nwp/jobs.py index 77ca5ba..7ca4d39 100644 --- a/nwp/jobs.py +++ b/nwp/jobs.py @@ -64,7 +64,7 @@ def build_config_on_runtime(model: str, run: str, delay: int = 0) -> dict: schedules.append(ScheduleDefinition(job=asset_job, cron_schedule="0 8 * * *")) -@daily_partitioned_config(start_date=dt.datetime(2021, 1, 1)) +@daily_partitioned_config(start_date=dt.datetime(2020, 1, 1)) def ecmwf_daily_partitioned_config_docker(start: dt.datetime, _end: dt.datetime): config: NWPConsumerConfig = NWPConsumerConfig( date_from=start.strftime("%Y-%m-%d"), @@ -94,6 +94,7 @@ def ecmwf_daily_partitioned_config(start: dt.datetime, _end: dt.datetime): return {"ops": { "nwp_consumer_download_op": {"config": json.loads(config.json())}, }} + @job(config=ecmwf_daily_partitioned_config) def ecmwf_daily_local_archive(): nwp_consumer_convert_op(nwp_consumer_download_op())