from xpander_sdk import Backend
from agno.agent import Agent

# Get all your workbench configuration
backend = Backend()
agent = Agent(**backend.get_args())

# Test the agent locally
agent.print_response("What can you help me with?")

from xpander_sdk import Tasks
import asyncio

async def handle_user_request(user_id: str, message: str):
    # Your app creates a task for xpander to process
    task = await Tasks().acreate(
        agent_id="your-agent-id",
        prompt=message,
        metadata={"user_id": user_id}  # Pass any context
    )

    # Wait for xpander to process it
    while task.status not in ["completed", "failed"]:
        await asyncio.sleep(1)
        task = await task.areload()

    # Return result to your users
    return task.result

from xpander_sdk import on_task, Backend, register_tool
from agno.agent import Agent

@register_tool
def query_inventory(sku: str) -> dict:
    """Your custom business logic"""
    # Connect to YOUR database, APIs, etc.
    return {"sku": sku, "quantity": 100}

@on_task
async def handle_task(task: Task):
    backend = Backend(configuration=task.configuration)
    agent = Agent(**backend.get_args())

    # Process with your custom tools available
    result = await agent.arun(message=task.to_message())
    task.result = result.content
    return task