Skip to content

Commit

Permalink
Update name of schedule
Browse files Browse the repository at this point in the history
  • Loading branch information
devsjc committed Sep 8, 2023
1 parent f832b8a commit 36f1db2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions nwp/jobs.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ def nwp_consumer_docker_job():
nwp_consumer_docker_op()

@schedule(job=nwp_consumer_docker_job, cron_schedule="0 13 * * *")
def ecmwf_daily_schedule(context: ScheduleEvaluationContext):
def ecmwf_daily_local_archive_schedule(context: ScheduleEvaluationContext):
scheduled_date = context.scheduled_execution_time.strftime("%Y-%m-%d")
return RunRequest(
run_key=None,
Expand All @@ -75,5 +75,5 @@ def ecmwf_daily_schedule(context: ScheduleEvaluationContext):
tags={"date": scheduled_date},
)

schedules.append(ecmwf_daily_schedule)
schedules.append(ecmwf_daily_local_archive_schedule)

0 comments on commit 36f1db2

Please sign in to comment.