René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"When making client calls from a sync env (with `asyncio.run()`) the loop gets closed after the first request, causing subsequent ones to fail","articleBody":"Whenever I make requests via the `GraphServiceClient` from a sync environment using `asyncio.run()` or `asgiref.sync.async_to_sync()` the first call succeeds, however, all subsequent calls fail with an error:\r\n\r\n```python\r\nTraceback (most recent call last):\r\n  File \"/app/some_path/some_file.py\", line 15, in get_drives\r\n    drives = asyncio.run(client.drives.get())\r\n  File \"/usr/local/lib/python3.11/asyncio/base_events.py\", line 653, in run_until_complete\r\n    return future.result()\r\n  File \"/usr/local/lib/python3.11/site-packages/msgraph/generated/drives/drive_request_builder.py\", line 66, in get\r\n    return await self.request_adapter.send_async(request_info, DriveItemCollectionResponse, error_mapping)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/httpx_request_adapter.py\", line 166, in send_async\r\n    response = await self.get_http_response_message(request_info, parent_span)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/httpx_request_adapter.py\", line 508, in get_http_response_message\r\n    resp = await self._http_client.send(request)\r\n  File \"/usr/local/lib/python3.11/site-packages/httpx/_client.py\", line 1617, in send\r\n    response = await self._send_handling_auth(\r\n  File \"/usr/local/lib/python3.11/site-packages/httpx/_client.py\", line 1645, in _send_handling_auth\r\n    response = await self._send_handling_redirects(\r\n  File \"/usr/local/lib/python3.11/site-packages/httpx/_client.py\", line 1682, in _send_handling_redirects\r\n    response = await self._send_single_request(request)\r\n  File \"/usr/local/lib/python3.11/site-packages/httpx/_client.py\", line 1719, in _send_single_request\r\n    response = await transport.handle_async_request(request)\r\n  File \"/usr/local/lib/python3.11/site-packages/msgraph_core/middleware/async_graph_transport.py\", line 21, in handle_async_request\r\n    response = await self.pipeline.send(request)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/middleware.py\", line 38, in send\r\n    return await self._first_middleware.send(request, self._transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/redirect_handler.py\", line 77, in send\r\n    response = await super().send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/middleware.py\", line 65, in send\r\n    return await self.next.send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/retry_handler.py\", line 83, in send\r\n    response = await super().send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/middleware.py\", line 65, in send\r\n    return await self.next.send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/parameters_name_decoding_handler.py\", line 55, in send\r\n    response = await super().send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/middleware.py\", line 65, in send\r\n    return await self.next.send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/url_replace_handler.py\", line 44, in send\r\n    response = await super().send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/middleware.py\", line 65, in send\r\n    return await self.next.send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/user_agent_handler.py\", line 29, in send\r\n    return await super().send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/middleware.py\", line 65, in send\r\n    return await self.next.send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/msgraph_core/middleware/telemetry.py\", line 48, in send\r\n    response = await super().send(request, transport)\r\n  File \"/usr/local/lib/python3.11/site-packages/kiota_http/middleware/middleware.py\", line 62, in send\r\n    response = await transport.handle_async_request(request)\r\n  File \"/usr/local/lib/python3.11/site-packages/msgraph_core/middleware/async_graph_transport.py\", line 24, in handle_async_request\r\n    response = await self.transport.handle_async_request(request)\r\n  File \"/usr/local/lib/python3.11/site-packages/httpx/_transports/default.py\", line 353, in handle_async_request\r\n    resp = await self._pool.handle_async_request(req)\r\n  File \"/usr/local/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 226, in handle_async_request\r\n    await self._close_expired_connections()\r\n  File \"/usr/local/lib/python3.11/site-packages/httpcore/_async/connection_pool.py\", line 194, in _close_expired_connections\r\n    await connection.aclose()\r\n  File \"/usr/local/lib/python3.11/site-packages/httpcore/_async/connection.py\", line 166, in aclose\r\n    await self._connection.aclose()\r\n  File \"/usr/local/lib/python3.11/site-packages/httpcore/_async/http11.py\", line 241, in aclose\r\n    await self._network_stream.aclose()\r\n  File \"/usr/local/lib/python3.11/site-packages/httpcore/_backends/anyio.py\", line 54, in aclose\r\n    await self._stream.aclose()\r\n  File \"/usr/local/lib/python3.11/site-packages/anyio/streams/tls.py\", line 195, in aclose\r\n    await self.transport_stream.aclose()\r\n  File \"/usr/local/lib/python3.11/site-packages/anyio/_backends/_asyncio.py\", line 1161, in aclose\r\n    self._transport.close()\r\n  File \"/usr/local/lib/python3.11/asyncio/selector_events.py\", line 860, in close\r\n    self._loop.call_soon(self._call_connection_lost, None)\r\n  File \"/usr/local/lib/python3.11/asyncio/base_events.py\", line 761, in call_soon\r\n    self._check_closed()\r\n  File \"/usr/local/lib/python3.11/asyncio/base_events.py\", line 519, in _check_closed\r\n    raise RuntimeError('Event loop is closed')\r\nRuntimeError: Event loop is closed\r\n```\r\n\r\nThe simplest example that reproduces this is:\r\n\r\n```python\r\nimport asyncio\r\nfrom azure.identity import ClientSecretCredential\r\nfrom msgraph import GraphServiceClient\r\n\r\ncredential = ClientSecretCredential(\r\n    'TENANT_ID',\r\n    'CLIENT_ID',\r\n    'CLIENT_SECRET')\r\nscopes = [\"https://graph.microsoft.com/.default\"]\r\nclient = GraphServiceClient(credential, scopes)\r\n\r\ndrives_1 = asyncio.run(client.drives.get())\r\ndrives_2 = asyncio.run(client.drives.get())\r\n```\r\n\r\nI use the GraphServiceClient inside a task run in a background worker (Django Q) alongside my Django app. So the first time the background task runs it succeeds, while the second time it fails.\r\n\r\nAs a workaround this does the trick:\r\n\r\n```python\r\ndef get_loop():\r\n    try:\r\n        loop = asyncio.get_event_loop()\r\n    except RuntimeError:\r\n        loop = asyncio.new_event_loop()\r\n        asyncio.set_event_loop(loop)\r\n    return loop\r\n\r\n# inside the background task\r\ndrives = get_loop().run_until_complete(client.drives.get())\r\n```","author":{"url":"https://github.com/aberezh","@type":"Person","name":"aberezh"},"datePublished":"2023-09-24T19:50:36.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":14},"url":"https://github.com/366/msgraph-sdk-python/issues/366"}