fix tests

Author: hallvictoria

azure_functions_worker_v2/tests/unittests/test_handle_event.py

@@ -93,7 +93,11 @@ async def test_worker_init_request_with_otel(self,
         self.assertIsNotNone(result.worker_metadata.worker_bitness)
         self.assertEqual(result.result.status, 1)
 
-    async def test_worker_init_request_with_exception(self):
+    @patch("azure_functions_worker_v2.handle_event"
+           ".otel_manager.get_azure_monitor_available",
+           return_value=False)
+    async def test_worker_init_request_with_exception(self,
+                                                      mock_otel_enabled):
         # If an exception happens during indexing, we return failure
         worker_request = WorkerRequest(name='worker_init_request',
                                        request=Request(FunctionRequest(

workers/tests/unittest_proxy/test_dispatcher.py

@@ -225,8 +225,8 @@ async def test_handle_function_load_request(mock_logger, mock_streaming):
 
     assert result == "mocked_stream_response"
     mock_logger.info.assert_called_with(
-        'Received WorkerLoadRequest, request ID %s, function_id: %s,function_name: %s, '
-        'worker_id: %s', "req789", "func123", "hello_function", "worker123"
+        'Received WorkerLoadRequest, request ID %s, function_id: %s, function_name: %s,'
+        ' worker_id: %s', "req789", "func123", "hello_function", "worker123"
     )
 
 
@@ -250,7 +250,7 @@ async def test_handle_invocation_request(mock_logger, mock_streaming):
 
     assert result == "mocked_streaming_response"
     mock_logger.info.assert_called_with(
-        'Received FunctionInvocationRequest, request ID %s, function_id: %s,'
+        'Received FunctionInvocationRequest, request ID %s, function_id: %s, '
         'invocation_id: %s, worker_id: %s',
         "req789", "func123", "inv123", "worker123"
     )