ray_app.py

from burr.integrations.ray import RayExecutor

persister = SQLitePersister(db_path="./db")
persister.initialize()
app = (
    ApplicationBuilder()
    .with_actions(user_input, final_results, generate_all_poems=GenerateAllPoems())
    .with_transitions(
        ("user_input", "generate_all_poems"),
        ("generate_all_poems", "final_results"),
    )
    .with_tracker(project="demo:parallel_agents_fault_tolerance")
    .with_parallel_executor(RayExecutor)
    .with_state_persister(persister)
    .initialize_from(
        persister,
        resume_at_next_action=True,
        default_state={},
        default_entrypoint="user_input"
    )
    .with_identifiers(app_id=app_id)
    .build()
)
return app