How to use the aiojobs._job.Job function in aiojobs
To help you get started, we’ve selected a few aiojobs examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
aio-libs / aiojobs / aiojobs / _scheduler.py View on Github 
async def spawn(self, coro):
if self._closed:
raise RuntimeError("Scheduling a new job after closing")
job = Job(coro, self, self._loop)
should_start = (self._limit is None or
self.active_count < self._limit)
self._jobs.add(job)
if should_start:
job._start()
else:
# wait for free slot in queue
await self._pending.put(job)
return jobaiojobs
Job scheduler for managing background tasks (asyncio)
