Merge pull request #69 from evaline-ju/weather-update

✨ Set temperature_unit to fahrenheit for weather example

Author: pdettori

a2a/weather_service/src/weather_service/agent.py

@@ -11,11 +11,9 @@
 from a2a.types import AgentCapabilities, AgentCard, AgentSkill, TaskState, TextPart
 from a2a.utils import new_agent_text_message, new_task
 from openinference.instrumentation.langchain import LangChainInstrumentor
-from pydantic import AnyUrl
 from langchain_core.messages import HumanMessage
 
 from weather_service.graph import get_graph, get_mcpclient
-from keycloak import KeycloakOpenID
 
 logging.basicConfig(level=logging.DEBUG)
 logger = logging.getLogger(__name__)
@@ -116,9 +114,9 @@ async def execute(self, context: RequestContext, event_queue: EventQueue):
             output = None
             # Test MCP connection first
             logger.info(f'Attempting to connect to MCP server at: {os.getenv("MCP_URL", "http://localhost:8000/sse")}')
-            
+
             mcpclient = get_mcpclient()
-            
+
             # Try to get tools to verify connection
             try:
                 tools = await mcpclient.get_tools()
@@ -127,7 +125,7 @@ async def execute(self, context: RequestContext, event_queue: EventQueue):
                 logger.error(f'Failed to connect to MCP server: {tool_error}')
                 await event_emitter.emit_event("Error: Cannot connect to MCP weather service at {os.getenv('MCP_URL', 'http://localhost:8000/sse')}. Please ensure the weather MCP server is running. Error: {tool_error}", failed=True)
                 return
-                
+
             graph = await get_graph(mcpclient)
             async for event in graph.astream(input, stream_mode="updates"):
                 await event_emitter.emit_event(
@@ -151,7 +149,7 @@ async def cancel(self, context: RequestContext, event_queue: EventQueue) -> None
         Not implemented
         """
         raise Exception("cancel not supported")
-    
+
 def run():
     """
     Runs the A2A Agent application.

mcp/weather_tool/Dockerfile

@@ -12,4 +12,3 @@ RUN chown -R 1001:1001 /app
 USER 1001
 
 CMD ["uv", "run", "--no-sync", "weather_tool.py"]
-

mcp/weather_tool/weather_tool.py

@@ -16,11 +16,12 @@ def get_weather(city: str) -> str:
         return "City not found"
     latitude = data["results"][0]["latitude"]
     longitude = data["results"][0]["longitude"]
-    
+
     weather_url = "https://api.open-meteo.com/v1/forecast"
     weather_params = {
         "latitude": latitude,
         "longitude": longitude,
+        "temperature_unit": "fahrenheit",
         "current_weather": True
     }
     weather_response = requests.get(weather_url, params=weather_params)
@@ -34,7 +35,7 @@ def run_server():
     transport = os.getenv("MCP_TRANSPORT", "streamable-http")
     host = os.getenv("HOST", "0.0.0.0")
     port = int(os.getenv("PORT", "8000"))
-    mcp.run(transport=transport, host=host, port=port) 
+    mcp.run(transport=transport, host=host, port=port)
 
 if __name__ == "__main__":
     run_server()