diff options
Diffstat (limited to 'apscheduler/executors/asyncio.py')
| -rw-r--r-- | apscheduler/executors/asyncio.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/apscheduler/executors/asyncio.py b/apscheduler/executors/asyncio.py index 5139622..1bdeb78 100644 --- a/apscheduler/executors/asyncio.py +++ b/apscheduler/executors/asyncio.py @@ -2,7 +2,9 @@ from __future__ import absolute_import import sys + from apscheduler.executors.base import BaseExecutor, run_job +from apscheduler.util import iscoroutinefunction_partial try: from asyncio import iscoroutinefunction @@ -46,7 +48,7 @@ class AsyncIOExecutor(BaseExecutor): else: self._run_job_success(job.id, events) - if iscoroutinefunction(job.func): + if iscoroutinefunction_partial(job.func): if run_coroutine_job is not None: coro = run_coroutine_job(job, job._jobstore_alias, run_times, self._logger.name) f = self._eventloop.create_task(coro) |