refactor connect CLI command

[tinalenguyen]

No description provided.

[theomonnom]

lgtm!

[theomonnom]

     loop = asyncio.get_event_loop()
+    _task: asyncio.Task | None = None
+
     @server.once("worker_started")
     def _simulate_job() -> None:
+        nonlocal _task
+
         async def simulate_job() -> None:
             async with api.LiveKitAPI(url, api_key, api_secret) as lk_api:
                 room_request = api.ListRoomsRequest(names=[room])
                 active_room = await lk_api.room.list_rooms(room_request)
                 if not active_room.rooms:
                     room_info = await lk_api.room.create_room(api.CreateRoomRequest(name=room))
                 else:
                     room_info = active_room.rooms[0]
             await server.simulate_job(
                 room=room,
                 fake_job=False,
                 room_info=room_info,
                 agent_identity=participant_identity,
             )
-        loop = asyncio.get_event_loop()
-        asyncio.run_coroutine_threadsafe(simulate_job(), loop)
+        _task = asyncio.create_task(simulate_job())

[theomonnom]

run_coroutine_threadsafe isn't needed here