Skip to content

Commit c216e2f

Browse files
committed
refactor scheduler
1 parent 69c7b7f commit c216e2f

1 file changed

Lines changed: 4 additions & 5 deletions

File tree

app/scheduler.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,17 @@
1-
21
from datetime import datetime
32
from rq_scheduler import Scheduler
43

54
from dependencies import get_redis
6-
from tasks import check_payment
5+
from tasks import check_payments
76

87
RUN_INTERVAL = 30
98

9+
1010
def create_scheduler():
1111
redis = get_redis()
1212
scheduler = Scheduler(connection=redis)
1313
scheduler.schedule(
1414
scheduled_time=datetime.utcnow(),
15-
func=check_payment,
15+
func=check_payments,
1616
interval=RUN_INTERVAL,
17-
18-
)
17+
)

0 commit comments

Comments
 (0)