|
@@ -43,7 +43,7 @@ _workers: dict[str, asyncio.Task] = {}
|
|
|
|
|
|
|
|
async def _spawn_worker(room_name: str):
|
|
async def _spawn_worker(room_name: str):
|
|
|
"""Run a worker for one room. Exits when room is empty or cancelled."""
|
|
"""Run a worker for one room. Exits when room is empty or cancelled."""
|
|
|
- from conversation_worker import Worker
|
|
|
|
|
|
|
+ from worker import Worker
|
|
|
try:
|
|
try:
|
|
|
logger.info("Worker starting room=%s", room_name)
|
|
logger.info("Worker starting room=%s", room_name)
|
|
|
w = Worker(room_name, identity="asr-bot")
|
|
w = Worker(room_name, identity="asr-bot")
|