Skip to content

_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)