Skip to content

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