session - lazily initialize event loop

Author: ischneider

planet/http.py

@@ -282,6 +282,12 @@ async def alog_response(*args, **kwargs):
         self._limiter = _Limiter(rate_limit=RATE_LIMIT, max_workers=MAX_ACTIVE)
         self.outcomes: Counter[str] = Counter()
 
+        self._loop: asyncio.AbstractEventLoop = None  # type: ignore
+
+    def _init_loop(self):
+        if self._loop:
+            return
+
         # create a dedicated event loop for this httpx session.
         def _start_background_loop(loop):
             asyncio.set_event_loop(loop)
@@ -294,6 +300,7 @@ def _start_background_loop(loop):
         self._loop_thread.start()
 
     def _call_sync(self, f: Awaitable[T]) -> T:
+        self._init_loop()
         return asyncio.run_coroutine_threadsafe(f, self._loop).result()
 
     @classmethod

tests/integration/test_orders_api.py

@@ -120,7 +120,7 @@ async def test_list_orders_basic(order_descriptions, session):
 
 
 @respx.mock
-def test_list_orders_basic_sync(order_descriptions, session):
+def test_list_orders_basic_sync(order_descriptions):
     next_page_url = TEST_ORDERS_URL + 'blob/?page_marker=IAmATest'
 
     order1, order2, order3 = order_descriptions
@@ -265,7 +265,7 @@ async def test_create_order_basic(oid,
 def test_create_order_basic_sync(oid,
                                  order_description,
                                  order_request,
-                                 session):
+                                 ):
     route = respx.post(TEST_ORDERS_URL)
     route.return_value = httpx.Response(HTTPStatus.OK, json=order_description)
 
@@ -337,7 +337,7 @@ async def test_get_order(oid, order_description, session):
 
 
 @respx.mock
-def test_get_order_sync(oid, order_description, session):
+def test_get_order_sync(oid, order_description, ):
     get_url = f'{TEST_ORDERS_URL}/{oid}'
     mock_resp = httpx.Response(HTTPStatus.OK, json=order_description)
     respx.get(get_url).return_value = mock_resp