From 57366d3ff7e400f2fbb0b2e285e2a6c2697b4644 Mon Sep 17 00:00:00 2001 From: Roman van der Krogt Date: Thu, 11 Sep 2025 01:23:03 +0100 Subject: [PATCH 1/2] pass api key to workflow --- src/mcp_agent/executor/temporal/system_activities.py | 1 + src/mcp_agent/server/app_server.py | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/mcp_agent/executor/temporal/system_activities.py b/src/mcp_agent/executor/temporal/system_activities.py index c065ea9fa..024632d79 100644 --- a/src/mcp_agent/executor/temporal/system_activities.py +++ b/src/mcp_agent/executor/temporal/system_activities.py @@ -65,6 +65,7 @@ async def relay_notify( ) -> bool: gateway_url = getattr(self.context, "gateway_url", None) gateway_token = getattr(self.context, "gateway_token", None) + return await notify_via_proxy( execution_id=execution_id, method=method, diff --git a/src/mcp_agent/server/app_server.py b/src/mcp_agent/server/app_server.py index 6dbdbd376..271cd013a 100644 --- a/src/mcp_agent/server/app_server.py +++ b/src/mcp_agent/server/app_server.py @@ -1399,7 +1399,7 @@ async def _workflow_run( try: # Prefer explicit kwargs, else infer from request context/headers gateway_url = kwargs.get("gateway_url") - gateway_token = kwargs.get("gateway_token") + gateway_token = kwargs.get("gateway_token") or app.config.temporal.api_key req = getattr(ctx.request_context, "request", None) if req is not None: From fe3bf14f8c11fbe882ade1790d6b073f579e62b7 Mon Sep 17 00:00:00 2001 From: Roman van der Krogt Date: Thu, 11 Sep 2025 01:36:27 +0100 Subject: [PATCH 2/2] guard against settings not existing --- src/mcp_agent/server/app_server.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/mcp_agent/server/app_server.py b/src/mcp_agent/server/app_server.py index 271cd013a..5e289a5e5 100644 --- a/src/mcp_agent/server/app_server.py +++ b/src/mcp_agent/server/app_server.py @@ -1399,7 +1399,10 @@ async def _workflow_run( try: # Prefer explicit kwargs, else infer from request context/headers gateway_url = kwargs.get("gateway_url") - gateway_token = kwargs.get("gateway_token") or app.config.temporal.api_key + gateway_token = kwargs.get("gateway_token") + if gateway_token is None: + if app and app.config and app.config.temporal: + gateway_token = app.config.temporal.api_key req = getattr(ctx.request_context, "request", None) if req is not None: