unit test fixes

Author: Victoria Hall

tests/unittests/test_dispatcher.py

@@ -602,6 +602,7 @@ class TestDispatcherStein(testutils.AsyncTestCase):
     def setUp(self):
         self._ctrl = testutils.start_mockhost(
             script_root=DISPATCHER_STEIN_FUNCTIONS_DIR)
+        config_manager.clear_config()
 
     async def test_dispatcher_functions_metadata_request(self):
         """Test if the functions metadata response will be sent correctly
@@ -668,6 +669,7 @@ def setUp(self):
             'azure_functions_worker.dispatcher.sys.version_info',
             SysVersionInfo(3, 9, 0, 'final', 0))
         self.mock_version_info.start()
+        config_manager.clear_config()
 
     def tearDown(self):
         os.environ.clear()

tests/unittests/test_extension.py

@@ -24,6 +24,7 @@
     ExtensionManager,
 )
 from azure_functions_worker.utils.common import get_sdk_from_sys_path
+from azure_functions_worker.utils.config_manager import clear_config
 
 
 class MockContext:
@@ -75,6 +76,7 @@ def setUp(self):
 
         # Set feature flag to on
         os.environ[PYTHON_ENABLE_WORKER_EXTENSIONS] = 'true'
+        clear_config()
 
     def tearDown(self) -> None:
         os.environ.pop(PYTHON_ENABLE_WORKER_EXTENSIONS)

tests/unittests/test_opentelemetry.py

@@ -7,6 +7,7 @@
 from tests.utils import testutils
 
 from azure_functions_worker import protos
+from azure_functions_worker.utils import config_manager
 
 
 class TestOpenTelemetry(unittest.TestCase):
@@ -15,6 +16,7 @@ def setUp(self):
         self.loop = asyncio.new_event_loop()
         asyncio.set_event_loop(self.loop)
         self.dispatcher = testutils.create_dummy_dispatcher()
+        config_manager.clear_config()
 
     def tearDown(self):
         self.loop.close()

tests/unittests/test_shared_memory_manager.py

@@ -32,7 +32,6 @@ class TestSharedMemoryManager(testutils.SharedMemoryTestCase):
     Tests for SharedMemoryManager.
     """
     def setUp(self):
-        config_manager.clear_config()
         env = os.environ.copy()
         env['FUNCTIONS_WORKER_SHARED_MEMORY_DATA_TRANSFER_ENABLED'] = "true"
         self.mock_environ = patch.dict('os.environ', env)
@@ -41,6 +40,7 @@ def setUp(self):
         self.mock_environ.start()
         self.mock_sys_module.start()
         self.mock_sys_path.start()
+        config_manager.clear_config()
 
     def tearDown(self):
         self.mock_sys_path.stop()
@@ -73,6 +73,7 @@ def test_is_disabled(self):
         # Make sure shared memory data transfer is disabled
         was_shmem_env_true = is_envvar_true(
             FUNCTIONS_WORKER_SHARED_MEMORY_DATA_TRANSFER_ENABLED)
+        config_manager.clear_config()
         os.environ.update(
             {FUNCTIONS_WORKER_SHARED_MEMORY_DATA_TRANSFER_ENABLED: '0'})
         manager = SharedMemoryManager()