8
8
from unittest .mock import patch
9
9
10
10
from azure_functions_worker import protos
11
+ from azure_functions_worker .version import VERSION
11
12
from tests .utils import testutils
12
13
from azure_functions_worker .constants import PYTHON_THREADPOOL_THREAD_COUNT , \
13
14
PYTHON_THREADPOOL_THREAD_COUNT_DEFAULT , \
@@ -64,6 +65,10 @@ async def test_dispatcher_initialize_worker(self):
64
65
self .assertIsInstance (r .response , protos .WorkerInitResponse )
65
66
self .assertIsInstance (r .response .worker_metadata ,
66
67
protos .WorkerMetadata )
68
+ self .assertEquals (r .response .worker_metadata .runtime_name ,
69
+ "python" )
70
+ self .assertEquals (r .response .worker_metadata .worker_version ,
71
+ VERSION )
67
72
68
73
async def test_dispatcher_environment_reload (self ):
69
74
"""Test function environment reload response
@@ -75,6 +80,10 @@ async def test_dispatcher_environment_reload(self):
75
80
protos .FunctionEnvironmentReloadResponse )
76
81
self .assertIsInstance (r .response .worker_metadata ,
77
82
protos .WorkerMetadata )
83
+ self .assertEquals (r .response .worker_metadata .runtime_name ,
84
+ "python" )
85
+ self .assertEquals (r .response .worker_metadata .worker_version ,
86
+ VERSION )
78
87
79
88
async def test_dispatcher_initialize_worker_logging (self ):
80
89
"""Test if the dispatcher's log can be flushed out during worker
0 commit comments