fix(skills): carry the caller's context into the worker thread

When resolve_plus_response bridges an async client from inside a running loop
it runs the coroutine on a worker thread, which starts with empty ContextVars.
A client reading runtime state there — the platform integration token, flow
context — would see defaults rather than the caller's values, which is hard to
diagnose from the resulting auth or routing failure.

Copy the context across, matching how the parallel-summarization bridge in this
module already does it.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>

Author: joaomdmoura

lib/crewai/src/crewai/utilities/agent_utils.py

@@ -108,10 +108,14 @@ async def await_response() -> Any:
         loop = None
 
     # asyncio.run() refuses to nest inside a running loop, so hand the coroutine
-    # to a worker thread with a loop of its own.
+    # to a worker thread with a loop of its own — carrying a copy of the caller's
+    # context, since a fresh thread would otherwise start with empty ContextVars
+    # and a client reading runtime state (the platform token, flow context) would
+    # see defaults.
     if loop and loop.is_running():
+        ctx = contextvars.copy_context()
         with concurrent.futures.ThreadPoolExecutor(max_workers=1) as pool:
-            return pool.submit(asyncio.run, await_response()).result()
+            return pool.submit(ctx.run, asyncio.run, await_response()).result()
 
     return asyncio.run(await_response())
 

lib/crewai/tests/utilities/test_agent_utils.py

@@ -1307,6 +1307,22 @@ async def main() -> Any:
 
         assert asyncio.run(main()) is response
 
+    def test_carries_context_vars_into_the_worker_thread(self) -> None:
+        """Inside a running loop the coroutine runs on another thread; a client
+        reading runtime state (the platform token, flow context) must still see
+        the caller's values rather than defaults."""
+        from crewai.context import get_platform_integration_token, platform_context
+        from crewai.utilities.agent_utils import resolve_plus_response
+
+        async def call() -> Any:
+            return get_platform_integration_token()
+
+        async def main() -> Any:
+            with platform_context("token-from-caller"):
+                return resolve_plus_response(call())
+
+        assert asyncio.run(main()) == "token-from-caller"
+
     def test_rejects_an_awaitable_bound_to_a_loop(self) -> None:
         from crewai.utilities.agent_utils import resolve_plus_response