import asyncio
from arq.worker import run_worker
from worker import WorkerSettings

# Create & set a loop BEFORE arq touches asyncio.get_event_loop()
asyncio.set_event_loop(asyncio.new_event_loop())


run_worker(WorkerSettings)