run()

async Class: JobsAustriaCacheProcess
File: jobs_austria_cache_process_data_payload.py · line 85

Signature

Parameters	none
Returns	not annotated
Async	Yes
Visibility	Public

Implementation

async def run(self):
    while True:
        logs.info("Checking scrape_cache for new URLs...")
        inserted = await self.process_once()

        if inserted == 0:
            logs.info("No new URLs found. Stopping.")
            break

        logs.info(f"Cycle complete. Inserted {inserted} rows total. Waiting {POLL_INTERVAL}s...")
        await asyncio.sleep(POLL_INTERVAL)