_drain_generator()

async Class: JobsAustriaDetailsETL
File: jobs_austria_details_scraping.py · line 201

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)