Removing the queue as its deprecated for 3.10

Author: vrdmr

azure_functions_worker/testutils.py

@@ -444,15 +444,14 @@ class _WorkerResponseMessages(typing.NamedTuple):
 class _MockWebHost:
 
     def __init__(self, loop, scripts_dir):
-        self._loop = loop
         self._scripts_dir = scripts_dir
 
         self._available_functions = {}
         self._read_available_functions()
 
         self._connected_fut = loop.create_future()
-        self._in_queue = queue.Queue()
-        self._out_aqueue = asyncio.Queue(loop=self._loop)
+        self._in_queue: queue.Queue = queue.Queue()
+        self._out_aqueue: asyncio.Queue = asyncio.Queue()
         self._threadpool = concurrent.futures.ThreadPoolExecutor(max_workers=1)
         self._server = grpc.server(self._threadpool)
         self._servicer = _MockWebHostServicer(self)
@@ -894,7 +893,8 @@ def start_webhost(*, script_dir=None, stdout=None):
                 time.sleep(2)
                 break
             else:
-                print(f'Failed to ping {health_check_endpoint}', flush=True)
+                print(f'Failed to ping {health_check_endpoint} Please check the'
+                      f' log file for details: {stdout.name}', flush=True)
         except requests.exceptions.ConnectionError:
             pass
         time.sleep(2)

tests/unittests/test_utilities.py

@@ -314,16 +314,16 @@ def parse_int_no_raise(value: str):
 
     def test_is_python_version(self):
         # Should pass at least 1 test
-        is_python_version_36 = common.is_python_version('3.6')
         is_python_version_37 = common.is_python_version('3.7')
         is_python_version_38 = common.is_python_version('3.8')
         is_python_version_39 = common.is_python_version('3.9')
+        is_python_version_310 = common.is_python_version('3.10')
 
         self.assertTrue(any([
-            is_python_version_36,
             is_python_version_37,
             is_python_version_38,
-            is_python_version_39
+            is_python_version_39,
+            is_python_version_310
         ]))
 
     def test_get_sdk_from_sys_path(self):