run()

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

Signature

Parameters	none
Returns	not annotated
Async	Yes
Visibility	Public

Implementation

async def run(self):
            self.apify_actor_loader.run()
            self.generators = self._create_generators()
            try:
                await self.produce_and_consume()
            except BaseException:
                await asyncio.gather(*[g.abort_run() for g in self.generators], return_exceptions=True) # this aborts the runs when there is an exception or manual stop
                raise