src/evaluators/run_evaluator.py

import time
from src.evaluators.evaluate import process_evaluation_queue


def evaluator_runner():
    
    print("Starting evaluator service...")
    
    while True:
        try:
            process_evaluation_queue()
            print("Evaluation queue processed. Sleeping for 1 minutes...")
            time.sleep(60)  # Sleep for 1 minutes
        except Exception as e:
            print(f"Error in evaluation process: {e}")
            print("Retrying in 1 minutes...")
            time.sleep(60)