{
"actor-start": {
"eventTitle": "Price for Actor start",
"eventDescription": "Flat fee for starting an Actor run.",
"eventPriceUsd": 0.1
},
"task-completed": {
"eventTitle": "Price for completing the task",
"eventDescription": "Flat fee for completing the task.",
"eventPriceUsd": 0.4
}
}
async def main():
"""Runs the AI Travel Planner workflow."""
async with Actor:
await Actor.charge('actor-start')
actor_input = await Actor.get_input() or {}
Actor.log.info(f"Received input: {actor_input}")
travel_query = TravelState(**actor_input)
# Execute workflow
final_state = travel_workflow.invoke(travel_query)
Actor.log.info(f"Workflow completed. Final state: {final_state}")
await Actor.charge('task-completed')
# Save the final report
await save_report(final_state)