Fixed scheduler import. (#171)

s3rius · web-flow · commit d322481e175b · 2023-07-11T13:14:44.000+04:00
diff --git a/taskiq/cli/scheduler/run.py b/taskiq/cli/scheduler/run.py
@@ -77,7 +77,7 @@ async def run_scheduler(args: SchedulerArgs) -> None:  # noqa: C901, WPS210, WPS
         scheduler = import_object(args.scheduler)
     else:
         scheduler = args.scheduler
-    if not isinstance(args.scheduler, TaskiqScheduler):
+    if not isinstance(scheduler, TaskiqScheduler):
         print(  # noqa: WPS421
             "Imported scheduler is not a subclass of TaskiqScheduler.",
         )

Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ async def run_scheduler(args: SchedulerArgs) -> None: # noqa: C901, WPS210, WPS`
`77`	`77`	`scheduler = import_object(args.scheduler)`
`78`	`78`	`else:`
`79`	`79`	`scheduler = args.scheduler`
`80`		`- if not isinstance(args.scheduler, TaskiqScheduler):`
	`80`	`+ if not isinstance(scheduler, TaskiqScheduler):`
`81`	`81`	`print( # noqa: WPS421`
`82`	`82`	`"Imported scheduler is not a subclass of TaskiqScheduler.",`
`83`	`83`	`)`