import asyncio
from temporalio.client import Client

async def main():
    print("Connecting to Temporal...")
    client = await Client.connect("temporal-frontend.ai-core.svc.cluster.local:7233")
    
    payload = {
        "text": "Remind me to call John at 4pm and send me a WhatsApp about it",
        "sender": "JohnDoe",
        "targetJid": "1234567890@s.whatsapp.net"
    }
    
    print(f"Executing workflow with payload: {payload}")
    result = await client.execute_workflow(
        "CentralOrchestratorWorkflow",
        payload,
        id=f"test-workflow-{asyncio.get_event_loop().time()}",
        task_queue="agents-orchestrator",
    )
    
    print(f"Workflow result: {result}")

if __name__ == "__main__":
    asyncio.run(main())