run_cycle()

Class: JobsAustriaCacheProcessRework
File: jobs_austria_cache_key_sync.py · line 91

One synchronous cycle of checking and updating.

Signature

Parameters	none
Returns	not annotated
Async	No
Visibility	Public

Implementation

def run_cycle(self):
    """One synchronous cycle of checking and updating."""
    df = self.get_pending_cache()

    # Stop if no more records exist with fk_job_id IS NULL
    if df.empty:
        return False

    df_enriched = self.enrich_with_existence(df)

    # Now this will correctly receive the integer count from the method above
    updated_count = self.update_cache_references(df_enriched)

    logs.info(f"Cycle finished. Found {len(df)} pending rows, updated {updated_count} references.")
    return True