src/evaluator/run_evaluator.py

import time
import sys
import signal
from src.evaluator.evaluate import process_evaluation_queue

def signal_handler(sig, frame):
    print("\nEvaluator shutting down...")
    sys.exit(0)

def main():
    # Register signal handler for graceful shutdown
    signal.signal(signal.SIGINT, signal_handler)
    
    print("Starting evaluator service...")
    
    while True:
        try:
            process_evaluation_queue()
            print("Evaluation queue processed. Sleeping for 5 minutes...")
            time.sleep(300)  # Sleep for 5 minutes
        except Exception as e:
            print(f"Error in evaluation process: {e}")
            print("Retrying in 5 minutes...")
            time.sleep(300)

if __name__ == "__main__":
    main()