# import sys, os # from dotenv import load_dotenv # load_dotenv() # # Add the path to the local folder to sys.path # sys.path.insert( # 0, os.path.abspath("../../..") # ) # Adds the parent directory to the system path - for litellm local dev # def start_rq_worker(): # from rq import Worker, Queue, Connection # from redis import Redis # # Set up RQ connection # redis_conn = Redis( # host=os.getenv("REDIS_HOST"), # port=os.getenv("REDIS_PORT"), # password=os.getenv("REDIS_PASSWORD"), # ) # print(redis_conn.ping()) # Should print True if connected successfully # # Create a worker and add the queue # try: # queue = Queue(connection=redis_conn) # worker = Worker([queue], connection=redis_conn) # except Exception as e: # print(f"Error setting up worker: {e}") # exit() # with Connection(redis_conn): # worker.work() # start_rq_worker()