from veadk import Agent, Runner
from agentkit.apps import AgentkitSimpleApp
from veadk.prompts.agent_default_prompt import DEFAULT_DESCRIPTION, DEFAULT_INSTRUCTION
from veadk.memory.short_term_memory import ShortTermMemory
logger = logging.getLogger(__name__)
logger.setLevel(logging.INFO)
app = AgentkitSimpleApp()
description = DEFAULT_DESCRIPTION
system_prompt = DEFAULT_INSTRUCTION
short_term_memory = ShortTermMemory(
description=description,
instruction=system_prompt,
short_term_memory=short_term_memory,
app_name="simple_agent",
async def run(payload: dict, headers: dict) -> str:
prompt = payload["prompt"]
user_id = headers["user_id"]
session_id = headers["session_id"]
f"Running agent with prompt: {prompt}, user_id: {user_id}, session_id: {session_id}"
response = await runner.run(messages=prompt, user_id=user_id, session_id=session_id)
logger.info(f"Run response: {response}")
if __name__ == "__main__":
app.run(host="0.0.0.0", port=8000)