from features.sequences.shipping import ShippedSequence ORCHESTRATION = ShippedSequence( title="Orchestrating a board", brief="The user pressed Play, and you run the board: its tickets run in order, each with an agent of its own in its own " "worktree, and you see every ticket through to its merge. You do not do the tickets' work yourself, and you stay free " "for anything else the user asks. Each moment of a ticket comes to you as a short sequence of its own, ahead of this one.", starts_on="board.started", lasting=True, steps=[ ("Tell the user", "Say once, in one short message, what Play does: journal message create \"I'm running now: " "tickets, each with its own agent in its own worktree, merged into in order. I review their plans " "and merge their work, and I'll only ask you what I can't decide. You can keep asking me for anything " "else.\" (journal board show gives the board, its branch and its goal)."), ("Read the board", "Read the board and its cards: journal board show and journal ticket board . Note the " "order the tickets must run in, the waits between them, and which are queued, running or done."), ("Take on the decisions", "The board's decisions are yours: Play gave you plan approvals, the waits between cards and the " "drafts (journal board show shows the three switches). Review and approve each ticket's " "plan with journal ticket approve_plan , or send it back with journal ticket send_back " "\"\"; accept or decline proposed waits with journal ticket accept_dependencies or " "decline_dependencies --why \"\"; confirm drafts with journal ticket confirm --why " "\"\". Accept the waits between the cards now. The user keeps the checkpoints and any change " "to the board's goal; say so in one line. When auto mode is on, the questions the ticket agents file are yours as " "well: answer them with journal --env question answer --how \"\" " "--set reason=\"\", and write down what you chose; go to the user only for " "what needs them: a secret or a login, anything outward-facing or in production."), ("Start the tickets", "Choose each ticket's model as you would for any dispatch, the least expensive one that does the job " "well, then move every ticket into the board's start stage in the order they must run: journal ticket " "move \"\" --model . A ticket started without a model is refused. Each agent " "starts in its own worktree; beyond the running limit, and behind the tickets they wait on, they queue " "and start as slots free."), ("Hand off", "From here this sequence only waits: each moment of a ticket (a plan to review, a checkpoint, finished work, a " "conflict, a ticket sent back twice, a stuck agent) and the board being paused or finished comes as a short " "sequence of its own. When two arrive together, merges go first, since a merge frees a slot. Never start the " "user's own work inside a ticket's sequence. Move on with journal sequence next --about " "once the board is finished and closed."), ], ) FIND_IT = "journal ticket show names its environment, its plan and the board it is on." REVIEWING_A_PLAN = ShippedSequence( title="Reviewing a ticket's plan", brief="A ticket's plan waits for your approval. Review it against the ticket before you approve anything.", starts_on="ticket.plan_waits", steps=[ ("Read the ticket and its plan", f"{FIND_IT} Read the ticket's card and the plan with journal --env plan read " ". If the board's plan_reviewer is a subagent, dispatch the plan-reviewer agent " "type for this and the next step."), ("Check it does the ticket and nothing more", "Every phase and to-do serves the ticket's card, none does work the card does not ask " "for, and it ends with the card's done-when true."), ("Approve it or send it back", "Approve it with journal ticket approve_plan , or send it back with what must change and " "why: journal ticket send_back \"\". A ticket sent back twice is escalated to " "the user by itself."), ], ) PASSING_A_CHECKPOINT = ShippedSequence( title="Passing a checkpoint", brief="A ticket's plan stopped at a checkpoint. Check the phase before it, then let it go on, so the board never waits overnight.", starts_on="ticket.checkpoint", steps=[ ("Check the phase before it", f"{FIND_IT} Read where it stands with journal --env plan progress , and " "check the phase before the checkpoint did what it says."), ("Let it go on", "Continue it with journal ticket continue_plan , or send it back with what to fix first: journal " "ticket send_back \"\"."), ], ) MERGING_A_TICKET = ShippedSequence( title="Merging a ticket", brief="A ticket finished its plan with a clean worktree. Check its work before it lands on the board's branch.", starts_on="ticket.finished", steps=[ ("Review its work", f"{FIND_IT} Dispatch the ticket-reviewer agent type: it runs the ticket's tests in its worktree and checks " "the diff against every done-when clause of its card, and answers pass or fail with evidence. On a fail, " "send it back with what failed (journal ticket send_back \"\") and abandon this run: " "it comes back when the ticket finishes again."), ("Merge it", "Merge it into the board's branch with journal ticket merge , never by hand; the ticket closes and the " "next one starts. When the merge is refused because the branches conflict, start Resolving a merge conflict: " "journal sequence run --about ticket:."), ], ) RESOLVING_A_CONFLICT = ShippedSequence( title="Resolving a merge conflict", brief="A ticket's merge was refused because its branch conflicts with the board's branch. Hand it back with exactly what to do.", steps=[ ("Name the conflict", f"{FIND_IT} In its worktree, try the merge without committing (git merge --no-commit --no-ff , " "then git merge --abort) to name the conflicting files, and read which merged ticket changed them."), ("Hand it to its agent", "Tell its agent: journal ticket tell \"Rebase onto ; conflicts in ; keep " "'s change to .\" Its next finish starts a fresh merge."), ], ) ESCALATING_A_TICKET = ShippedSequence( title="Escalating a ticket", brief="A ticket was sent back twice. Stop it and let the user decide; the rest of the board runs on.", starts_on="ticket.escalated", steps=[ ("Stop it", f"{FIND_IT} Stop its agent: journal ticket stop . Tickets that wait on it stay queued."), ("Ask the user", "Ask on the board with both reasons it was sent back: journal board ask \" was sent back " "twice: \" --set options='[{\"title\": \"Let me look\"}, {\"title\": \"Rewrite the card\"}, {\"title\": " "\"Drop it\"}]' --set pick=."), ("Act on the answer", "Let me look: leave it stopped and say so in the chat. Rewrite the card: dispatch the board-filler to revise " "it, then journal ticket start . Drop it: journal ticket delete --why \"\"."), ], ) UNSTICKING_A_TICKET_AGENT = ShippedSequence( title="Unsticking a ticket agent", brief="A ticket's agent is waiting on a prompt, silent, idle with nothing running, or gone. Get it working again.", starts_on="ticket.stuck", steps=[ ("Look at its screen", "journal ticket screen shows what its terminal says."), ("Get it going", "Answer what it waits on with journal ticket tell \"\", or restart it with journal ticket " "stop then journal ticket start ."), ("Report what a restart does not fix", "If this ticket was stuck before in the last 15 minutes, the fault is in the journal: send " "the agent-journal agent the exact command, its output and the ticket, then escalate it: " "journal sequence run --about ticket:."), ], ) PAUSING_A_BOARD = ShippedSequence( title="Pausing a board", brief="The user paused the board. Stop its running tickets and keep their worktrees until they resume it.", starts_on="board.paused", steps=[ ("Halt the tickets", "Stop every running ticket of the board: journal ticket stop for each (journal ticket board " "shows which run). Their worktrees stay. Say it in the panel: journal board say \"Paused; " " tickets keep their worktrees.\""), ], ) RESUMING_A_BOARD = ShippedSequence( title="Resuming a board", brief="The user resumed the board. Start the tickets that were halted, in their order.", starts_on="board.resumed", steps=[ ("Start the halted tickets", "Start every ticket of the board that was stopped by the pause, in the order they must run: journal " "ticket start ."), ], ) CLOSING_A_BOARD = ShippedSequence( title="Closing a board", brief="The last ticket of a running board closed. Check the goal clause by clause and tell the user.", starts_on="board.finished", steps=[ ("Check the goal", "Dispatch the goal-verifier agent type for the board: it runs the full tests on the board's branch and checks " "every done-when clause of the board's goal for real, answering met or not met with evidence. A clause that " "no card the user kept covers is left out by choice, not failed."), ("Close the gap", "If a clause is not met, dispatch the board-filler to draft only the missing cards (journal board expect " " --fewer \"only what is missing\"), and tell the user what is missing in one line; " "pressing Play again runs them. Otherwise go on."), ("Report", "Write the update: journal report changes, then journal report recap \": reached (or what is left). " ". Landed on : . Sent back: . Escalated: .\""), ], ) ORCHESTRATING_MOMENTS = (REVIEWING_A_PLAN, PASSING_A_CHECKPOINT, MERGING_A_TICKET, RESOLVING_A_CONFLICT, ESCALATING_A_TICKET, UNSTICKING_A_TICKET_AGENT, PAUSING_A_BOARD, RESUMING_A_BOARD, CLOSING_A_BOARD)