remove extra call

Author: hallvictoria

runtimes/v1/azure_functions_runtime_v1/utils/executor.py

@@ -26,7 +26,6 @@ def execute_sync(function, args) -> Any:
 def run_sync_func(invocation_id, context, func, params):
     # This helper exists because we need to access the current
     # invocation_id from ThreadPoolExecutor's threads.
-    context.thread_local_storage.invocation_id = invocation_id
     token = invocation_id_cv.set(invocation_id)
     try:
         result = functools.partial(execute_sync, func)

runtimes/v2/azure_functions_runtime/utils/executor.py

@@ -25,7 +25,6 @@ def execute_sync(function, args) -> Any:
 def run_sync_func(invocation_id, context, func, params):
     # This helper exists because we need to access the current
     # invocation_id from ThreadPoolExecutor's threads.
-    context.thread_local_storage.invocation_id = invocation_id
     token = invocation_id_cv.set(invocation_id)
     try:
         result = functools.partial(execute_sync, func)

workers/azure_functions_worker/dispatcher.py

@@ -1013,7 +1013,6 @@ def _create_sync_call_tp(
     def _run_sync_func(self, invocation_id, context, func, params):
         # This helper exists because we need to access the current
         # invocation_id from ThreadPoolExecutor's threads.
-        context.thread_local_storage.invocation_id = invocation_id
         try:
             return ExtensionManager.get_sync_invocation_wrapper(context,
                                                                 func)(params)

workers/tests/unittests/test_opentelemetry.py

@@ -8,6 +8,7 @@
 from tests.utils import testutils
 
 from azure_functions_worker import protos
+from azure_functions_worker.protos.FunctionRpc_pb2 import RpcTraceContext
 
 
 class TestOpenTelemetry(unittest.TestCase):
@@ -309,7 +310,7 @@ def test_otel_configured_before_first_log_in_invocation_request(
             invocation_request=protos.InvocationRequest(
                 invocation_id="test-inv-123",
                 function_id="test-func-id",
-                trace_context=protos.RpcTraceContext(
+                trace_context=RpcTraceContext(
                     trace_parent="00-trace-parent",
                     trace_state="state"
                 )
@@ -392,7 +393,7 @@ def test_azure_monitor_configured_before_first_log(
             invocation_request=protos.InvocationRequest(
                 invocation_id="test-inv-456",
                 function_id="test-func-id",
-                trace_context=protos.RpcTraceContext(
+                trace_context=RpcTraceContext(
                     trace_parent="00-trace-parent",
                     trace_state="state"
                 )
@@ -466,7 +467,7 @@ def test_otel_configured_before_first_log_sync_function(
             invocation_request=protos.InvocationRequest(
                 invocation_id="test-inv-sync",
                 function_id="test-func-id",
-                trace_context=protos.RpcTraceContext(
+                trace_context=RpcTraceContext(
                     trace_parent="00-trace-parent",
                     trace_state="state"
                 )