File size: 505 Bytes
9d7aae7
bde1c71
9d7aae7
 
e92e200
9d7aae7
 
 
 
 
 
cec147a
 
9d7aae7
 
cec147a
 
9d7aae7
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
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)