janakiramm

import datetime
from zoneinfo import ZoneInfo
from google.adk.agents import Agent

def get_weather(city: str) -> dict:
    """Retrieves the current weather report for a specified city.

    Args:
        city (str): The name of the city for which to retrieve the weather report.

janakiramm

import os
import asyncio
from google.adk.agents import Agent
from google.adk.sessions import InMemorySessionService
from google.adk.runners import Runner
from google.genai import types  

import warnings
warnings.filterwarnings("ignore")

janakiramm

apiVersion: gateway.networking.k8s.io/v1
kind: HTTPRoute
metadata:
  name: echo-route
  namespace: demo
spec:
  parentRefs:
  - name: demo-gateway
    namespace: nginx-gateway
  rules:

janakiramm

apiVersion: gateway.networking.k8s.io/v1
kind: Gateway
metadata:
  name: demo-gateway
  namespace: nginx-gateway
spec:
  gatewayClassName: nginx
  listeners:
  - name: http
    protocol: HTTP

janakiramm

---
apiVersion: v1
kind: Namespace
metadata:
  name: demo
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: demo-app

janakiramm

### Part 1 - Imports
import os
import sys
import asyncio
import logging
import re
from typing import Optional, Dict, Any

from google.adk.agents import LlmAgent, SequentialAgent
from google.adk.runners import Runner

janakiramm

## Part 1 - Import modules
import asyncio
import logging
from typing import Dict, TypedDict

from google.adk.agents import LlmAgent 
from google.adk.sessions import InMemorySessionService
from google.adk.runners import Runner
from google.genai import types

janakiramm

# client.py
import asyncio
from fastmcp import Client
from fastmcp.client.elicitation import ElicitResult
from google import genai
from google.genai import types

async def send_to_gemini(flight_status_result: str, user_query: str = None):
    """Send flight status result to Gemini for analysis."""
    try:

janakiramm

# server.py
from fastmcp import FastMCP, Context
from dataclasses import dataclass
import httpx
import os
from datetime import datetime, timedelta
import pytz

mcp = FastMCP("Flight Status Server")

janakiramm

import os
import asyncio
from google import genai
from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client

import warnings
warnings.filterwarnings("ignore")

MCP_SERVER_URL = "http://127.0.0.1:8080/mcp/"