Address feedback and make test_higher_concurrency more resilient

Author: AdrianAtZyte

scrapy_zyte_api/_middlewares.py

@@ -13,6 +13,7 @@
     _LOG_DEFERRED_IS_DEPRECATED,
     _close_spider,
     _schedule_coro,
+    maybe_deferred_to_future,
 )
 
 logger = getLogger(__name__)
@@ -188,7 +189,13 @@ def __init__(self, crawler):
         if _LOG_DEFERRED_IS_DEPRECATED:
             self._send_signal = crawler.signals.send_catch_log_async
         else:
-            self._send_signal = crawler.signals.send_catch_log_deferred
+
+            async def _send_signal(signal, **kwargs):
+                await maybe_deferred_to_future(
+                    crawler.signals.send_catch_log_deferred(signal, **kwargs)
+                )
+
+            self._send_signal = _send_signal
 
     @staticmethod
     def _get_header_set(request):

tests/test_api_requests.py

@@ -339,7 +339,7 @@ async def test_higher_concurrency():
     response_indexes = []
     expected_first_index = concurrency - 1
     fast_seconds = 0.001
-    slow_seconds = 0.2
+    slow_seconds = 0.4
 
     def _build_request(index: int) -> Request:
         return Request(