File tree Expand file tree Collapse file tree 6 files changed +791
-49
lines changed
Expand file tree Collapse file tree 6 files changed +791
-49
lines changed Original file line number Diff line number Diff line change @@ -30,11 +30,6 @@ from apscheduler.schedulers.blocking import BlockingScheduler
3030from apscheduler_di import ContextSchedulerDecorator
3131
3232# pip install redis
33- job_defaults: Dict[str , RedisJobStore] = {
34- " default" : RedisJobStore(
35- jobs_key = " dispatched_trips_jobs" , run_times_key = " dispatched_trips_running"
36- )
37- }
3833job_stores: Dict[str , RedisJobStore] = {
3934 " default" : RedisJobStore(
4035 jobs_key = " dispatched_trips_jobs" , run_times_key = " dispatched_trips_running"
@@ -53,8 +48,7 @@ def tick(tack: Tack):
5348
5449
5550def main ():
56- scheduler = ContextSchedulerDecorator(BlockingScheduler(jobstores = job_stores,
57- job_defaults = job_defaults))
51+ scheduler = ContextSchedulerDecorator(BlockingScheduler(jobstores = job_stores))
5852 scheduler.ctx.add_instance(Tack(), Tack)
5953 scheduler.add_executor(' processpool' )
6054 scheduler.add_job(tick, ' interval' , seconds = 3 )
Original file line number Diff line number Diff line change 99from apscheduler_di .decorator import ContextSchedulerDecorator
1010
1111# pip install redis
12- job_defaults : Dict [str , RedisJobStore ] = {
13- "default" : RedisJobStore (
14- jobs_key = "dispatched_trips_jobs" , run_times_key = "dispatched_trips_running"
15- )
16- }
1712job_stores : Dict [str , RedisJobStore ] = {
1813 "default" : RedisJobStore (
1914 jobs_key = "dispatched_trips_jobs" , run_times_key = "dispatched_trips_running"
@@ -56,8 +51,7 @@ async def some_infinite_cycle():
5651
5752
5853def run_scheduler ():
59- scheduler = ContextSchedulerDecorator (AsyncIOScheduler (jobstores = job_stores ,
60- job_defaults = job_defaults ))
54+ scheduler = ContextSchedulerDecorator (AsyncIOScheduler (jobstores = job_stores ))
6155 scheduler .ctx .add_instance (PostgresCatsRepository (), ICatsRepository )
6256 scheduler .ctx .add_instance (Config (some_param = 1 ), Config )
6357 scheduler .add_job (some_job , trigger = "interval" , seconds = 5 )
Original file line number Diff line number Diff line change 77from apscheduler_di import ContextSchedulerDecorator
88
99# pip install redis
10- job_defaults : Dict [str , RedisJobStore ] = {
11- "default" : RedisJobStore (
12- jobs_key = "dispatched_trips_jobs" , run_times_key = "dispatched_trips_running"
13- )
14- }
1510job_stores : Dict [str , RedisJobStore ] = {
1611 "default" : RedisJobStore (
1712 jobs_key = "dispatched_trips_jobs" , run_times_key = "dispatched_trips_running"
@@ -30,7 +25,7 @@ def tick(tack: Tack):
3025
3126
3227def main ():
33- scheduler = ContextSchedulerDecorator (BlockingScheduler ())
28+ scheduler = ContextSchedulerDecorator (BlockingScheduler (jobstores = job_stores ))
3429 scheduler .ctx .add_instance (Tack (), Tack )
3530 scheduler .add_executor ('processpool' )
3631 scheduler .add_job (tick , 'interval' , seconds = 3 )
Original file line number Diff line number Diff line change 88from apscheduler_di .decorator import ContextSchedulerDecorator
99
1010# pip install redis
11- job_defaults : Dict [str , RedisJobStore ] = {
12- "default" : RedisJobStore (
13- jobs_key = "dispatched_trips_jobs" , run_times_key = "dispatched_trips_running"
14- )
15- }
1611job_stores : Dict [str , RedisJobStore ] = {
1712 "default" : RedisJobStore (
1813 jobs_key = "dispatched_trips_jobs" , run_times_key = "dispatched_trips_running"
@@ -32,8 +27,7 @@ async def some_infinite_cycle():
3227def run_scheduler ():
3328 token = "1443372:AAEL5UPVPoruXeX9fqoD_6f-1Qk7AHQ"
3429 bot = Bot (token )
35- scheduler = ContextSchedulerDecorator (AsyncIOScheduler (jobstores = job_stores ,
36- job_defaults = job_defaults ))
30+ scheduler = ContextSchedulerDecorator (AsyncIOScheduler (jobstores = job_stores ))
3731 scheduler .ctx .add_instance (bot , Bot )
3832 scheduler .add_job (send_message_by_timer , trigger = "interval" , seconds = 5 )
3933 scheduler .start ()
You can’t perform that action at this time.
0 commit comments