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 3 minutes...")
            time.sleep(180)  # Sleep for 3 minutes
        except Exception as e:
            print(f"Error in evaluation process: {e}")
            print("Retrying in 3 minutes...")
            time.sleep(180)

if __name__ == "__main__":
    main()