diff --git a/ai_ref_kits/agentic_multimodal_travel_planer/agents/agent_runner.py b/ai_ref_kits/agentic_multimodal_travel_planer/agents/agent_runner.py
new file mode 100644
index 00000000..a3a758bf
--- /dev/null
+++ b/ai_ref_kits/agentic_multimodal_travel_planer/agents/agent_runner.py
@@ -0,0 +1,442 @@
+#!/usr/bin/env python3
+"""
+Generic Agent Runner - Modular script to run any A2A agent based on YAML config.
+It reads configuration from config/agents_config.yaml and prompts from
+config/agent_prompts.yaml.
+
+This script can run:
+- Regular agents with MCP tools
+- Supervisor agents that coordinate other agents via HandoffTools
+- All agents can be run in daemon mode for background operation
+"""
+
+import sys
+from pathlib import Path
+import argparse
+import asyncio
+import multiprocessing
+import os
+from contextlib import AsyncExitStack
+import requests
+import yaml
+import re
+
+from mcp.client.sse import sse_client
+from mcp.client.session import ClientSession
+
+from beeai_framework.agents.requirement import RequirementAgent
+from beeai_framework.agents.requirement.requirements.conditional import (
+ ConditionalRequirement,
+)
+from beeai_framework.adapters.a2a.agents.agent import A2AAgent
+from beeai_framework.adapters.a2a.serve.server import (
+ A2AServer,
+ A2AServerConfig,
+)
+from beeai_framework.backend import ChatModel, ChatModelParameters
+from beeai_framework.memory import UnconstrainedMemory
+from beeai_framework.middleware.trajectory import GlobalTrajectoryMiddleware
+from beeai_framework.serve.utils import LRUMemoryManager
+from beeai_framework.tools import Tool
+from beeai_framework.tools.handoff import HandoffTool
+from beeai_framework.tools.mcp import MCPTool
+
+# Add parent directory to path for imports (before local imports!)
+sys.path.append(str(Path(__file__).parent.parent)) # noqa: E402
+from utils.util import load_config
+
+# =============================================================================
+# MCP TOOLS MANAGEMENT
+# =============================================================================
+
+
+class MCPToolsManager:
+ """Manages MCP server connections and tool discovery"""
+
+ async def setup_mcp_tools_with_stack(self, config, stack):
+ """Setup MCP tools using AsyncExitStack for proper connection management. If the connection fails, the error is caught and the loop continues to the next server."""
+ mcp_config = config.get('mcp_config')
+ if not mcp_config:
+ return []
+ # Handle both old single-server format and new multi-server format
+ servers = (
+ [{'name': 'default', 'url': mcp_config['url'], 'enabled': True}]
+ if 'url' in mcp_config
+ else mcp_config.get('servers', [])
+ )
+
+ if not servers:
+ return []
+
+ enabled_servers = [s for s in servers if s and s.get('enabled', True)]
+ if not enabled_servers:
+ return []
+
+ all_mcp_tools = []
+
+ for server_config in enabled_servers:
+ server_url = server_config['url'] + "/sse"
+
+ try:
+ read_stream, write_stream = await stack.enter_async_context(
+ sse_client(server_url)
+ )
+ session = await stack.enter_async_context(
+ ClientSession(read_stream, write_stream)
+ )
+ await session.initialize()
+
+ mcp_tools = await MCPTool.from_client(session)
+ all_mcp_tools.extend(mcp_tools)
+
+ except (ConnectionError, OSError, TimeoutError):
+ continue
+
+ return all_mcp_tools
+
+# =============================================================================
+# AGENT CREATION
+# =============================================================================
+
+
+class AgentFactory:
+ """Factory class for creating different types of agents"""
+
+ def create_agent(self, config, tools=None, agent_name=None):
+ """Create an agent from configuration (regular or supervisor)"""
+ if 'supervised_agents' in config:
+ return self._create_supervisor_agent(config, tools)
+ else:
+ return self._create_regular_agent(config, tools)
+
+ def _create_regular_agent(self, config, tools=None):
+ """Create a regular A2A agent from configuration"""
+ llm = ChatModel.from_name(
+ config['llm_model'],
+ ChatModelParameters(temperature=config['llm_temperature'])
+ )
+ llm.tool_choice_support = {"auto", "none"}
+
+ # Create middleware if enabled
+ middlewares = []
+
+ middleware_config = config['middleware']['trajectory']
+ if middleware_config.get('enabled', True):
+ middlewares.append(GlobalTrajectoryMiddleware(
+ included=(
+ [Tool, ChatModel]
+ if "ChatModel" in middleware_config['included_types']
+ else [Tool]
+ ),
+ pretty=middleware_config['pretty'],
+ prefix_by_type={Tool: middleware_config['tool_prefix']}
+ ))
+
+
+ # Handle tool configuration
+ # If tools are provided externally (MCP tools), use them
+ # Otherwise, check if tools is a list in config
+ if tools:
+ agent_tools = tools
+ else:
+ tools_config = config.get('tools', [])
+ # If tools is a dict with mcp_tools: true, it means
+ # tools are loaded externally
+ if (isinstance(tools_config, dict) and
+ tools_config.get('mcp_tools', False)):
+ # Empty for now, will be loaded by run_agent
+ agent_tools = []
+ else:
+ agent_tools = (
+ tools_config if isinstance(tools_config, list) else []
+ )
+
+ print(f"Agent using {len(agent_tools)} tools")
+ if agent_tools:
+ print(" Connected tools:")
+ for i, tool in enumerate(agent_tools, 1):
+ tool_type = type(tool).__name__
+ print(f" {i}. {tool.name} ({tool_type})")
+ else:
+ print(" No tools connected")
+
+ # Process requirements
+ requirements = []
+ if agent_tools:
+ for r in config.get('requirements', []):
+ tool_instance = next(
+ (t for t in agent_tools if t.name == r["tool_name"]),
+ None
+ )
+ if tool_instance:
+ kwargs = {k: v for k, v in r.items() if k != "tool_name"}
+ # Evaluate string lambdas in custom_checks to callable functions
+ if "custom_checks" in kwargs and isinstance(kwargs["custom_checks"], list):
+ import re
+ kwargs["custom_checks"] = [
+ eval(check) if isinstance(check, str) else check
+ for check in kwargs["custom_checks"]
+ ]
+ requirements.append(ConditionalRequirement(
+ tool_instance, **kwargs
+ ))
+
+ return RequirementAgent(
+ llm=llm,
+ tools=agent_tools,
+ memory=UnconstrainedMemory(),
+ instructions=config['prompt'],
+ middlewares=middlewares,
+ name=config.get('name'),
+ description=config.get('description'),
+ requirements=requirements
+ )
+
+ def _create_supervisor_agent(self, config, mcp_tools=None):
+ """Create a SUPERVISOR agent
+ that coordinates other agents
+ via HandoffTools"""
+
+ available_agents, agent_cards = self._discover_supervised_agents(
+ config
+ )
+
+ print("***********CREATING SUPERVISOR AGENT***********")
+ # Create supervisor tools (HandoffTools)
+ supervisor_tools = []
+ for agent_name, agent_instance in available_agents.items(
+ ):
+ agent_description = agent_cards.get(agent_name, {}).get(
+ "description", agent_name
+ )
+ supervisor_tools.append(HandoffTool(
+ name=agent_name,
+ description=agent_description,
+ target=agent_instance
+ ))
+
+ # Combine MCP tools with HandoffTools if provided
+ if mcp_tools:
+ all_tools = mcp_tools + supervisor_tools
+ print(
+ f"Supervisor using {len(mcp_tools)} MCP tools + "
+ f"{len(supervisor_tools)} HandoffTools = "
+ f"{len(all_tools)} total tools"
+ )
+ print(" MCP tools:")
+ for i, tool in enumerate(mcp_tools, 1):
+ tool_type = type(tool).__name__
+ print(f" {i}. {tool.name} ({tool_type})")
+ print(" HandoffTools:")
+ for i, tool in enumerate(supervisor_tools, 1):
+ tool_type = type(tool).__name__
+ # Show target agent info - get URL/name, fallback to string
+ target_info = (
+ getattr(tool._target, 'url', None)
+ or getattr(tool._target, 'name', None)
+ or str(tool._target)
+ )
+ print(f" {i}. {tool.name} ({tool_type}) -> {target_info}")
+ else:
+ all_tools = supervisor_tools
+ print(
+ f"Supervisor using {len(supervisor_tools)} "
+ f"HandoffTools (no MCP tools)"
+ )
+ print(" HandoffTools:")
+ for i, tool in enumerate(supervisor_tools, 1):
+ tool_type = type(tool).__name__
+ # Show target agent info - get URL/name, fallback to string
+ target_info = (
+ getattr(tool._target, 'url', None)
+ or getattr(tool._target, 'name', None)
+ or str(tool._target)
+ )
+ print(f" {i}. {tool.name} ({tool_type}) -> {target_info}")
+
+ return self._create_regular_agent(config, all_tools)
+
+ def _discover_supervised_agents(self, config):
+ """Discover A2A agents that the supervisor can delegate to"""
+ available_agents = {}
+ agent_cards = {}
+
+ if 'supervised_agents' not in config:
+ return available_agents, agent_cards
+
+ for agent_config in config['supervised_agents']:
+ agent_name = agent_config['name']
+ agent_url = agent_config['url']
+
+ # Override URL with environment variable if available
+ port_env_var = agent_config.get('port_env_var')
+ if port_env_var and port_env_var in os.environ:
+ port = os.environ[port_env_var]
+ base_url = agent_url.rsplit(':', 1)[0]
+ agent_url = f"{base_url}:{port}"
+
+ try:
+ agent_card_url = f"{agent_url}/.well-known/agent-card.json"
+ response = requests.get(agent_card_url, timeout=5)
+
+ if response.status_code == 200:
+ agent_card = response.json()
+ agent_cards[agent_name] = agent_card
+ available_agents[agent_name] = A2AAgent(
+ url=agent_url, memory=UnconstrainedMemory()
+ )
+ print(f"{agent_name}: Connected successfully")
+ else:
+ print(
+ f"{agent_name}: Agent card not found "
+ f"(HTTP {response.status_code})"
+ )
+
+ except requests.RequestException as e:
+ print(f" {agent_name}: Not accessible ({e})")
+
+ print(f"Discovered {len(available_agents)} A2A agents for supervision")
+ return available_agents, agent_cards
+
+# =============================================================================
+# SERVER MANAGEMENT
+# =============================================================================
+
+
+class ServerManager:
+ """Manages A2A server creation and lifecycle"""
+
+ def create_server(self, agent, config):
+ """Create and configure the A2A server"""
+ return A2AServer(
+ config=A2AServerConfig(port=config['port']),
+ memory_manager=LRUMemoryManager(
+ maxsize=config['memory_size']
+ )
+ ).register(
+ agent, name=config['name'], description=config['description']
+ )
+
+# =============================================================================
+# UTILITY FUNCTIONS
+# =============================================================================
+
+
+class ConfigManager:
+ """Manages configuration loading and agent discovery"""
+
+ @staticmethod
+ def get_available_agents():
+ """Dynamically get available agents from config directory"""
+ config_dir = Path(__file__).parent.parent / "config"
+ config_file = config_dir / "agents_config.yaml"
+
+ if not config_file.exists():
+ return []
+
+ with open(config_file, 'r', encoding='utf-8') as f:
+ agents_config = yaml.safe_load(f)
+
+ return list(agents_config.keys())
+
+# =============================================================================
+# MAIN AGENT RUNNER
+# =============================================================================
+
+
+class AgentRunner:
+ """Main orchestrator class for running agents"""
+
+ def __init__(self):
+ self.mcp_manager = MCPToolsManager()
+ self.agent_factory = AgentFactory()
+ self.server_manager = ServerManager()
+ self.config_manager = ConfigManager()
+ self.agent_instance = None # Store agent reference
+
+ def reset_agent_memory(self):
+ """Reset the memory of the agent instance"""
+ if self.agent_instance and hasattr(self.agent_instance, 'memory'):
+ self.agent_instance.memory.reset()
+ print("Agent memory reset successfully")
+
+ async def run_agent(self, agent_name):
+ """Run an agent based on its configuration.
+
+ Args:
+ agent_name: Name of the agent to run from config
+ """
+ config = load_config(agent_name)
+ mcp_config = config.get('mcp_config')
+ has_valid_mcp = mcp_config and (
+ 'url' in mcp_config or
+ ('servers' in mcp_config and mcp_config['servers'])
+ )
+
+ if has_valid_mcp:
+ # Keep AsyncExitStack alive for the entire agent lifecycle
+ async with AsyncExitStack() as stack:
+ all_mcp_tools = (
+ await self.mcp_manager.setup_mcp_tools_with_stack(
+ config, stack
+ )
+ )
+ if not all_mcp_tools:
+ return
+ agent = self.agent_factory.create_agent(
+ config, all_mcp_tools, agent_name
+ )
+ self.agent_instance = agent # Store agent reference
+ server = self.server_manager.create_server(agent, config)
+
+ # Run server in the same process to keep MCP connections alive
+ print(f"Starting {agent_name} with MCP tools...")
+ try:
+ await asyncio.to_thread(server.serve)
+ except KeyboardInterrupt:
+ print(f"\n{agent_name} stopped")
+ else:
+ agent = self.agent_factory.create_agent(config, None, agent_name)
+ self.agent_instance = agent # Store agent reference
+ server = self.server_manager.create_server(agent, config)
+
+ process = multiprocessing.Process(target=server.serve)
+ process.start()
+
+ try:
+ while process.is_alive():
+ await asyncio.sleep(1)
+ except (KeyboardInterrupt, asyncio.CancelledError):
+ process.terminate()
+ process.join()
+
+ def get_available_agents(self):
+ """Get list of available agents"""
+ return self.config_manager.get_available_agents()
+
+
+def main():
+ """Main entry point"""
+ runner = AgentRunner()
+ available_agents = runner.get_available_agents()
+
+ parser = argparse.ArgumentParser(description='Generic A2A Agent Runner')
+ parser.add_argument(
+ '--agent',
+ choices=available_agents,
+ help=f'Agent to run. Available: {", ".join(available_agents)}'
+ )
+ args = parser.parse_args()
+
+ try:
+ asyncio.run(runner.run_agent(args.agent))
+ except KeyboardInterrupt:
+ pass
+ except (RuntimeError, ValueError) as e:
+ print(f"Error starting {args.agent}: {e}")
+ sys.exit(1)
+
+
+if __name__ == "__main__":
+ main()
+
diff --git a/ai_ref_kits/agentic_multimodal_travel_planer/config/agents_config.yaml b/ai_ref_kits/agentic_multimodal_travel_planer/config/agents_config.yaml
new file mode 100644
index 00000000..58d6d3cd
--- /dev/null
+++ b/ai_ref_kits/agentic_multimodal_travel_planer/config/agents_config.yaml
@@ -0,0 +1,211 @@
+# Agents Configuration File
+
+# Travel Router Agent Configuration (Supervisor)
+travel_router:
+ name: "travel_router"
+ description: "Intelligent travel coordinator that provides accurate, realistic travel information by consulting specialized agents"
+ port: 9996
+ role: "Travel Coordinator Supervisor"
+ enabled: true
+
+ # LLM Configuration for Travel Router
+ llm:
+ model: "openai:OpenVINO/Qwen3-8B-int4-ov"
+ temperature: 0.3
+ api_key: "unused"
+ api_base: "http://127.0.0.1:8001/v3"
+
+ # Memory Configuration
+ memory_size: 100
+
+ # Supervised Agents Configuration. It means that the travel_router agent can delegate to the following agents.
+ supervised_agents:
+ - name: "hotel_finder"
+ url: "http://127.0.0.1:9999"
+ - name: "flight_finder"
+ url: "http://127.0.0.1:9998"
+ - name: "image_captioning"
+ url: "http://127.0.0.1:9997"
+
+ # Tools Configuration (supervisor specific)
+ tools:
+ - name: "ThinkTool"
+ enabled: true # Disable it if you want to improve response time, tool for planning
+ - name: "HandoffTool"
+ enabled: true
+ auto_discovered: true
+
+ # Middleware Configuration
+ middleware:
+ trajectory:
+ included_types: ["Tool"]
+ pretty: true
+ tool_prefix: "π "
+
+ # Requirements with custom_checks to validate info before delegating
+ requirements:
+ - tool_name: "flight_finder"
+ custom_checks:
+ - "lambda state: any(re.search(r'\\b(yes|correct|ok|sure|go ahead|proceed|that\\'s right|right|confirmed)\\b', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user') or any(re.search(r'\\b(from|departure|leaving|origin|flying from)\\s+[A-Z][a-z]{2,}|^[A-Z][a-z]{2,}\\s+(to|destination)', msg.text) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user')"
+ - "lambda state: any(re.search(r'\\b(yes|correct|ok|sure|go ahead|proceed|that\\'s right|right|confirmed)\\b', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user') or any(re.search(r'\\b(to|destination|going|arriving|flying to)\\s+[A-Z][a-z]{2,}|[A-Z][a-z]{2,}\\s+(from|departure)', msg.text) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user')"
+ - "lambda state: any(re.search(r'\\b(yes|correct|ok|sure|go ahead|proceed|that\\'s right|right|confirmed)\\b', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user') or any(re.search(r'\\b(\\d{4}-\\d{2}-\\d{2}|\\d{1,2}[/-]\\d{1,2}[/-]\\d{2,4}|(jan|feb|mar|apr|may|jun|jul|aug|sep|oct|nov|dec)[a-z]*\\s+\\d{1,2}|\\d{1,2}\\s+(jan|feb|mar|apr|may|jun|jul|aug|sep|oct|nov|dec)[a-z]*|march|april|may|june|july|august|september|october|november|december|january|february)', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user')"
+ - "lambda state: any(re.search(r'\\b(yes|correct|ok|sure|go ahead|proceed|that\\'s right|right|confirmed)\\b', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user') or any(re.search(r'\\b(return|returning|inbound|back|come back|march|april|may|june|july|august|september|october|november|december|january|february|jan|feb|mar|apr|may|jun|jul|aug|sep|oct|nov|dec)', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user')"
+ - "lambda state: any(re.search(r'\\b(yes|correct|ok|sure|go ahead|proceed|that\\'s right|right|confirmed)\\b', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user') or any(re.search(r'\\b(economy|business|first|coach)\\b', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text') and hasattr(msg, 'role') and msg.role == 'user')"
+ - tool_name: "hotel_finder"
+ custom_checks:
+ - "lambda state: any(re.search(r'\\b(in|at|to|destination)\\s+[a-z]+', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text'))"
+ - "lambda state: any(re.search(r'\\b(check.?in|arrival|arriving).*?\\d{4}-\\d{2}-\\d{2}|\\d{1,2}[/-]\\d{1,2}[/-]\\d{2,4}', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text'))"
+ - "lambda state: any(re.search(r'\\b(check.?out|departure|leaving).*?\\d{4}-\\d{2}-\\d{2}|\\d{1,2}[/-]\\d{1,2}[/-]\\d{2,4}', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text'))"
+ - "lambda state: any(re.search(r'\\b(\\d+|one|two|three|four|five|six|seven|eight|nine|ten)\\s+(guest|people|person|adult)', msg.text.lower()) for msg in state.memory.messages if hasattr(msg, 'text'))"
+
+
+# Flight Finder Agent Configuration
+flight_finder:
+ name: "flight_finder"
+ description: "Specialized agent for flight search"
+ port: 9998
+ role: "Flight Search Specialist"
+ enabled: true
+
+ llm:
+ model: "openai:OpenVINO/Qwen3-8B-int4-ov"
+ temperature: 0.3
+ api_key: "unused"
+ api_base: "http://127.0.0.1:8001/v3"
+
+ # Memory Configuration
+ memory_size: 100
+
+ mcp_config:
+ servers:
+ - name: "Flight_search_api"
+ url: "http://127.0.0.1:3002"
+ protocol: "sse"
+ description: "Flight search"
+ enabled: true
+
+ # Memory Configuration
+ memory_size: 5
+
+ # Tools Configuration
+ tools:
+ mcp_tools: true
+
+ # Tools Configuration specify if it would use mcp_tools or beeai api tools
+ tools:
+ mcp_tools: true
+
+ # Middleware Configuration
+ middleware:
+ trajectory:
+ included_types: ["Tool"]
+ pretty: true
+ tool_prefix: "π "
+
+ # BeeAI rules requirements, useful to force agent behaviour
+ requirements:
+ - tool_name: "search_flights"
+ force_at_step: 1
+ max_invocations: 2
+
+# Hotel Finder Agent Configuration
+# Hotel Finder Agent Configuration
+hotel_finder:
+ name: "hotel_finder"
+ description: "Specialized agent for hotel search with access to hotel search tools"
+ port: 9999
+ role: "Hotel Search Specialist"
+ enabled: true
+
+ # LLM Configuration
+ llm:
+ model: "openai:Qwen/Qwen3-8B"
+ temperature: 0.3
+ api_key: "unused"
+ api_base: "http://127.0.0.1:8001/v3"
+
+ mcp_config:
+ servers:
+ - name: "Hotel Search Tool"
+ url: "http://127.0.0.1:3001"
+ protocol: "sse"
+ description: "Hotel search tool to get prices and accomodation places"
+ enabled: true
+
+
+ # Memory Configuration
+ memory_size: 5
+
+ # Tools Configuration
+ tools:
+ - name: "ThinkTool"
+ enabled: true
+ - name: "mcp_tools"
+ enabled: true
+ - name: "FinalAnswerTool"
+ enabled: true
+
+ # Middleware Configuration (For console logging)
+ middleware:
+ trajectory:
+ included_types: ["Tool", "ChatModel"]
+ pretty: true
+ tool_prefix: "π "
+
+ # BeeAI rules requirements, useful to force agent behaviour
+ requirements:
+ - tool_name: "search_hotels"
+ force_at_step: 1
+ max_invocations: 2
+
+# Video Analysis Agent Configuration
+image_captioning:
+ name: "image_captioning"
+ description: "Image captioning agent with 2 core tools: image ingestion and image captioning"
+ port: 9997
+ role: "Video Analysis Specialist"
+ enabled: true
+ # LLM Configuration for Video Search
+ llm:
+ model: "openai:OpenVINO/Qwen3-8B-int4-ov"
+ temperature: 0.3
+ api_key: "unused"
+ api_base: "http://127.0.0.1:8001/v3"
+
+ # MCP Configuration for image captioning
+ mcp_config:
+ url: "http://localhost:3003"
+ protocol: "sse"
+ description: "Image captioning tool to get captions for images"
+ enabled: true
+
+ # Memory Configuration
+ memory_size: 5
+
+ # Requirements - Force tool usage
+ requirements:
+ - tool_name: "ingest_videos"
+ force_at_step: 1
+ max_invocations: 1
+ # Tools Configuration (MCP-based)
+ tools:
+ type: "mcp_tools"
+ source: "mcp_server"
+
+ # Middleware Configuration
+ middleware:
+ trajectory:
+ enabled: false # Video agent doesn't use trajectory middleware
+
+###########################################################
+# EXAMPLE FOR HELPER RULES FOR AGENTS
+# Explore https://framework.beeai.dev/modules/agents/requirement-agent to know more about the requirements
+###########################################################
+# requirements:
+# - tool_name: "list_hotels"
+# force_at_step: 1
+# max_invocations: 2
+# - tool_name: "search_hotels"
+# only_after: ["list_hotels"]
+# - tool_name: "search_flights"
+# max_invocations: 0
\ No newline at end of file
diff --git a/ai_ref_kits/agentic_multimodal_travel_planer/config/agents_prompts.yaml b/ai_ref_kits/agentic_multimodal_travel_planer/config/agents_prompts.yaml
new file mode 100644
index 00000000..daa40a3e
--- /dev/null
+++ b/ai_ref_kits/agentic_multimodal_travel_planer/config/agents_prompts.yaml
@@ -0,0 +1,119 @@
+# Agents Prompts File
+# This file contains all prompts/instructions for different agents
+
+# Travel Router Agent Prompt (Supervisor)
+travel_router_prompt: |
+ You are a travel assistant. Follow these steps:
+
+ FOR FLIGHTS:
+ STEP 1: Collect ALL required information:
+ - from (departure city)
+ - to (destination city)
+ - departure_date
+ - return_date
+ - class
+
+ If ANY is missing, use final_answer to ask for it.
+
+ STEP 2: Once you have ALL 5 values, send confirmation:
+ Use final_answer with the ACTUAL values the user provided. Replace placeholders with real values from the conversation.
+ Format: "I will search for flights from [actual_from_city] to [actual_to_city], departing [actual_departure_date], returning [actual_return_date], in [actual_class]. Is this correct?"
+
+ STEP 3: Wait for user confirmation:
+ - If user says "yes", "correct", "ok", "sure", "go ahead", "proceed", "that's right" β Use HandoffTool[flight_finder]
+ - If user says "no" or corrects β Go back to STEP 1
+
+ STEP 4: After confirmation, delegate with ACTUAL values:
+ HandoffTool[flight_finder] with {"from": "[actual_from_city]", "to": "[actual_to_city]", "departure_date": "[actual_departure_date]", "return_date": "[actual_return_date]", "class": "[actual_class]"}
+
+ IMPORTANT: Use the actual values from the conversation, never use placeholders like [FROM] or [TO] in your responses.
+
+ FOR HOTELS:
+ STEP 1: Collect ALL required information:
+ - destination (city)
+ - check_in_date
+ - check_out_date
+ - guests
+
+ If ANY is missing, use final_answer to ask for it.
+
+ STEP 2: Once you have ALL 4 values, send confirmation:
+ Use final_answer with the ACTUAL values the user provided. Replace placeholders with real values from the conversation.
+ Format: "I will search for hotels in [actual_destination] from [actual_check_in] to [actual_check_out] for [actual_guests] guests. Is this correct?"
+
+ IMPORTANT: Use the actual values from the conversation, never use placeholders in your responses.
+
+ STEP 3: Wait for user confirmation, then delegate with HandoffTool[hotel_finder]
+
+ FOR IMAGES:
+ When user provides an image or asks about an image:
+ Use HandoffTool[image_captioning] with {"task": "