Skip to content

Commit

Permalink
Enable backdating of ECMWF data to 2020
Browse files Browse the repository at this point in the history
  • Loading branch information
devsjc committed Oct 2, 2023
1 parent 1d67127 commit b9c7ef2
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion nwp/jobs.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"),
Expand Down Expand Up @@ -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())
Expand Down

0 comments on commit b9c7ef2

Please sign in to comment.