Skip to content

produce_apify_results()

async Class: JobsAustriaETLCache
File: jobs_austria_cache_import.py ยท line 67

Signature

Parameters none
Returns not annotated
Async Yes
Visibility Public

Implementation

async def produce_apify_results(self):
    await asyncio.gather(*[self._drain_generator(g) for g in self.generators])
    await self.queue.put(None)  # poison pill to stop consumer