Fixed unit and docker tests

.github/workflows/ci_docker_con_workflow.yml

@@ -16,7 +16,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: [ 3.7, 3.8, 3.9, "3.10" ]
+        python-version: [ 3.7, 3.8, 3.9, "3.10", "3.11" ]
     permissions: read-all
     env:
         CONSUMPTION_DOCKER_TEST: "true"

tests/endtoend/test_file_name_functions.py

@@ -24,11 +24,12 @@ class TestHttpFunctionsFileName(testutils.WebHostTestCase):
     @classmethod
     def setUpClass(cls):
         os.environ["PYTHON_SCRIPT_FILE_NAME"] = "main.py"
+        cls.env_variables['PYTHON_SCRIPT_FILE_NAME'] = 'main.py'
         super().setUpClass()
 
     @classmethod
     def tearDownClass(cls):
-        # Remove the WEBSITE_HOSTNAME environment variable
+        # Remove the PYTHON_SCRIPT_FILE_NAME environment variable
         os.environ.pop('PYTHON_SCRIPT_FILE_NAME')
         super().tearDownClass()
 
@@ -38,6 +39,10 @@ def get_script_dir(cls):
                                             'http_functions_stein' / \
                                             'file_name'
 
+    @classmethod
+    def get_environment_variables(cls):
+        return cls.env_variables
+
     @testutils.retryable_test(3, 5)
     def test_index_page_should_return_ok(self):
         """The index page of Azure Functions should return OK in any

tests/unittests/test_dispatcher.py

@@ -143,7 +143,8 @@ async def test_dispatcher_sync_threadpool_default_worker(self):
         correct default value
         """
         async with self._ctrl as host:
-            # await self._check_if_function_is_ok(host)
+            await host.init_worker()
+            await self._check_if_function_is_ok(host)
             await self._assert_workers_threadpool(self._ctrl, host,
                                                   self._default_workers)
 
@@ -154,6 +155,7 @@ async def test_dispatcher_sync_threadpool_set_worker(self):
         os.environ.update({PYTHON_THREADPOOL_THREAD_COUNT:
                            f'{self._allowed_max_workers}'})
         async with self._ctrl as host:
+            await host.init_worker()
             await self._check_if_function_is_ok(host)
             await self._assert_workers_threadpool(self._ctrl, host,
                                                   self._allowed_max_workers)
@@ -335,10 +337,11 @@ async def test_async_invocation_request_log(self):
                                  )
 
     async def test_sync_invocation_request_log_threads(self):
-        os.environ.update({PYTHON_THREADPOOL_THREAD_COUNT: '5'})
-
         with patch('azure_functions_worker.dispatcher.logger') as mock_logger:
+            os.environ.update({PYTHON_THREADPOOL_THREAD_COUNT: '5'})
+
             async with self._ctrl as host:
+                await host.init_worker()
                 request_id: str = self._ctrl._worker._request_id
                 func_id, invoke_id, func_name = (
                     await self._check_if_function_is_ok(host)
@@ -359,10 +362,11 @@ async def test_sync_invocation_request_log_threads(self):
                                  )
 
     async def test_async_invocation_request_log_threads(self):
-        os.environ.update({PYTHON_THREADPOOL_THREAD_COUNT: '4'})
-
         with patch('azure_functions_worker.dispatcher.logger') as mock_logger:
+            os.environ.update({PYTHON_THREADPOOL_THREAD_COUNT: '4'})
+
             async with self._ctrl as host:
+                await host.init_worker()
                 request_id: str = self._ctrl._worker._request_id
                 func_id, invoke_id, func_name = (
                     await self._check_if_async_function_is_ok(host)

tests/unittests/test_enable_debug_logging_functions.py

@@ -35,6 +35,7 @@ def setUpClass(cls):
 
     @classmethod
     def tearDownClass(cls):
+        os.environ.pop(PYTHON_ENABLE_DEBUG_LOGGING)
         super().tearDownClass()
         cls._patch_environ.stop()
 
@@ -72,6 +73,7 @@ def setUpClass(cls):
 
     @classmethod
     def tearDownClass(cls):
+        os.environ.pop(PYTHON_ENABLE_DEBUG_LOGGING)
         super().tearDownClass()
         cls._patch_environ.stop()
 
@@ -118,6 +120,7 @@ def tearDownClass(cls):
         host_json = TESTS_ROOT / cls.get_script_dir() / 'host.json'
         remove_path(host_json)
 
+        os.environ.pop(PYTHON_ENABLE_DEBUG_LOGGING)
         super().tearDownClass()
         cls._patch_environ.stop()
 

tests/unittests/test_invalid_stein.py

@@ -1,12 +1,8 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License.
-import collections as col
-
 from azure_functions_worker import protos
 from tests.utils import testutils
 
-SysVersionInfo = col.namedtuple("VersionInfo", ["major", "minor", "micro",
-                                                "releaselevel", "serial"])
 STEIN_INVALID_APP_FUNCTIONS_DIR = testutils.UNIT_TESTS_FOLDER / \
     'broken_functions' / \
     'invalid_app_stein'
@@ -17,24 +13,30 @@
 
 class TestInvalidAppStein(testutils.AsyncTestCase):
 
+    @testutils.retryable_test(4, 5)
     async def test_indexing_not_app(self):
-        """Test if the functions metadata response will be 0
-            when an invalid app is provided
-                """
-        mock_host = testutils.start_mockhost(
-            script_root=STEIN_INVALID_APP_FUNCTIONS_DIR)
-        async with mock_host as host:
+        """Test if the functions metadata status will be
+            Failure when an invalid app is provided
+        """
+        async with testutils.start_mockhost(
+                script_root=STEIN_INVALID_APP_FUNCTIONS_DIR) as host:
+            await host.init_worker()
             r = await host.get_functions_metadata()
             self.assertIsInstance(r.response, protos.FunctionMetadataResponse)
-            self.assertIn("Error", r.response.result.exception.message)
+            self.assertEqual(r.response.result.status,
+                             protos.StatusResult.Failure)
+            self.assertIsNotNone(r.response.result.exception.message)
 
+    @testutils.retryable_test(4, 5)
     async def test_indexing_invalid_app(self):
-        """Test if the functions metadata response will be 0
-            when an invalid app is provided
-                """
-        mock_host = testutils.start_mockhost(
-            script_root=STEIN_INVALID_APP_FUNCTIONS_DIR)
-        async with mock_host as host:
+        """Test if the functions metadata status will be
+            Failure when an invalid app is provided
+        """
+        async with testutils.start_mockhost(
+                script_root=STEIN_INVALID_FUNCTIONS_DIR) as host:
+            await host.init_worker()
             r = await host.get_functions_metadata()
             self.assertIsInstance(r.response, protos.FunctionMetadataResponse)
-            self.assertIn("Error", r.response.result.exception.message)
+            self.assertEqual(r.response.result.status,
+                             protos.StatusResult.Failure)
+            self.assertIsNotNone(r.response.result.exception.message)