File tree Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Original file line number Diff line number Diff line change 1
1
import os
2
+ import pytz
2
3
import asyncio
3
4
from arq import create_pool
4
5
from logs import init_logging
5
- from datetime import datetime , timezone
6
+ from datetime import datetime
6
7
from arq .connections import RedisSettings
7
8
from apscheduler .schedulers .asyncio import AsyncIOScheduler
8
9
10
+ tz = pytz .timezone (os .environ .get ('TZ' , 'America/Argentina/Buenos_Aires' ))
11
+
9
12
10
13
async def tick ():
11
14
date_time_to_check = datetime .\
12
- now (timezone . utc ).replace (second = 0 , microsecond = 0 )
15
+ now (tz ).replace (second = 0 , microsecond = 0 )
13
16
logger .info (f"[Tick! Enqueuing job for { date_time_to_check } (UTC)]" )
14
17
await redis .enqueue_job ('alarm_manager' , date_time_to_check )
15
18
logger .info (f"[Tock! Job enqueued for { date_time_to_check } (UTC)" )
Original file line number Diff line number Diff line change @@ -8,4 +8,5 @@ requests_oauthlib
8
8
pyjwt
9
9
httpx
10
10
APScheduler >= 3.10 ,< 4.0
11
- arq
11
+ arq
12
+ pytz
You can’t perform that action at this time.
0 commit comments