_drain_generator()

async Class: JobsAustriaETLCache
File: jobs_austria_cache_import.py · line 63

Signature

Parameters	generator: ApifyGenerator
Returns	not annotated
Async	Yes
Visibility	Private

Implementation

async def _drain_generator(self, generator: ApifyGenerator):
    async for item in generator.run():
        await self.queue.put(item)