Skip to content

Commit

Permalink
feat: scheduler expressions in main.py
Browse files Browse the repository at this point in the history
  • Loading branch information
albertkun committed Feb 1, 2024
1 parent 5f2927e commit cb0836a
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion data-loading-service/app/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ def retry_on_failure(task, retries=5, delay=15):
def run_coroutine(coro):
loop = asyncio.get_event_loop()
return loop.run_until_complete(coro)

@crython.job(second='*/15')
def gtfs_rt_scheduler():
if not lock.locked():
Expand All @@ -37,7 +38,7 @@ def go_pass_data_scheduler():
except Exception as e:
print('Error updating Go Pass data ' + str(e))

@crython.job(expr='* */15 * * * * *')
@crython.job(expr='*/15 * * * *')
def canceled_trips_update_scheduler():
try:
update_canceled_trips.run_update()
Expand Down

0 comments on commit cb0836a

Please sign in to comment.