2020)
2121
2222
23+ _real_import = builtins .__import__
24+
25+
2326class TestDispatcher (unittest .TestCase ):
2427
2528 @patch ("proxy_worker.dispatcher.queue.Queue" )
@@ -304,7 +307,6 @@ def get_threadpool_executor():
304307 return_value = False )
305308@patch ("proxy_worker.dispatcher.logger" )
306309@patch ("proxy_worker.dispatcher.os.path.exists" , side_effect = lambda p : True )
307- @patch ("builtins.__import__" )
308310@patch ("proxy_worker.dispatcher.protos.StreamingMessage" ,
309311 return_value = "mocked_init_response" )
310312@patch ("proxy_worker.dispatcher.check_python_eol" )
@@ -316,7 +318,7 @@ async def test_worker_init_starts_threadpool(mock_eol, mock_streaming,
316318 def fake_import (name , * a , ** k ):
317319 if name == "azure_functions_runtime" :
318320 return runtime_module
319- return builtins . __import__ (name , * a , ** k )
321+ return _real_import (name , * a , ** k )
320322
321323 mock_import .side_effect = fake_import
322324 dispatcher = Dispatcher (asyncio .get_event_loop (), "localhost" , 7071 ,
@@ -332,7 +334,6 @@ def fake_import(name, *a, **k):
332334@patch ("proxy_worker.dispatcher.DependencyManager.prioritize_customer_dependencies" )
333335@patch ("proxy_worker.dispatcher.logger" )
334336@patch ("proxy_worker.dispatcher.os.path.exists" , side_effect = lambda p : True )
335- @patch ("builtins.__import__" )
336337@patch ("proxy_worker.dispatcher.protos.StreamingMessage" ,
337338 return_value = "mocked_reload_response" )
338339@patch ("proxy_worker.dispatcher.check_python_eol" )
@@ -344,7 +345,7 @@ async def test_env_reload_starts_threadpool(mock_eol, mock_streaming,
344345 def fake_import (name , * a , ** k ):
345346 if name == "azure_functions_runtime" :
346347 return runtime_module
347- return builtins . __import__ (name , * a , ** k )
348+ return _real_import (name , * a , ** k )
348349
349350 mock_import .side_effect = fake_import
350351 dispatcher = Dispatcher (asyncio .get_event_loop (), "localhost" , 7071 ,
@@ -366,7 +367,6 @@ def fake_import(name, *a, **k):
366367 return_value = False )
367368@patch ("proxy_worker.dispatcher.logger" )
368369@patch ("proxy_worker.dispatcher.os.path.exists" , side_effect = lambda p : True )
369- @patch ("builtins.__import__" )
370370@patch ("proxy_worker.dispatcher.protos.StreamingMessage" ,
371371 return_value = "mocked_init_response" )
372372@patch ("proxy_worker.dispatcher.check_python_eol" )
@@ -379,7 +379,7 @@ async def test_worker_init_missing_threadpool_apis(mock_eol,
379379 def fake_import (name , * a , ** k ):
380380 if name == "azure_functions_runtime" :
381381 return runtime_module
382- return builtins . __import__ (name , * a , ** k )
382+ return _real_import (name , * a , ** k )
383383
384384 mock_import .side_effect = fake_import
385385 dispatcher = Dispatcher (asyncio .get_event_loop (), "localhost" , 7071 ,
0 commit comments