scriptoriumadmin/fabro
1
0
Fork 0
mirror of https://github.com/fabro-sh/fabro.git synced 2026-10-08 03:10:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

fabro(01KP8XFY02RXHCR69H9FQ02X64): fixup (success)

Browse source 
Fabro-Run: 01KP8XFY02RXHCR69H9FQ02X64
Fabro-Completed: 9
Fabro-Checkpoint: 986054dc90

⚒️ Generated with [Fabro](https://fabro.sh)
This commit is contained in:
Fabro 2026-04-15 17:11:51 +00:00
parent 7c60c04525
commit e409b6b54e
3 changed files with 11 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lib/crates/fabro-cli/src/commands/run/wait.rs
View file

@ -49,10 +49,7 @@ pub(crate) async fn run(
.status
.map(|record| record.status);
let Some(status) = fallback_polled_status(polled_status, started_waiting_at) else {
bail!(
"Run '{}' has no status record yet. Try again in a moment.",
run_id
);
bail!("Run '{run_id}' has no status record yet. Try again in a moment.");
};
if status.is_terminal() {

7
lib/crates/fabro-cli/src/commands/runs/list.rs
View file

@ -149,9 +149,10 @@ fn status_cell(status: Option<RunStatus>, use_color: bool) -> CellStruct {
let color = match status {
RunStatus::Completed => Some(Color::Green),
RunStatus::Failed | RunStatus::Cancelled => Some(Color::Red),
RunStatus::Running | RunStatus::Starting | RunStatus::Submitted | RunStatus::Queued => {
Some(Color::Cyan)
}
RunStatus::Running
| RunStatus::Starting
| RunStatus::Submitted
| RunStatus::Queued => Some(Color::Cyan),
RunStatus::Blocked | RunStatus::Removing => Some(Color::Yellow),
RunStatus::Paused => Some(Color::Magenta),
};

9
lib/crates/fabro-server/src/server.rs
View file

@ -3290,19 +3290,22 @@ fn update_live_run_from_event(state: &Arc<AppState>, run_id: RunId, event: &RunE
}
EventBody::InterviewCompleted(props) => {
managed_run.pending_interviews.remove(&props.question_id);
if managed_run.status == RunStatus::Blocked && managed_run.pending_interviews.is_empty() {
if managed_run.status == RunStatus::Blocked && managed_run.pending_interviews.is_empty()
{
managed_run.status = RunStatus::Running;
}
}
EventBody::InterviewTimeout(props) => {
managed_run.pending_interviews.remove(&props.question_id);
if managed_run.status == RunStatus::Blocked && managed_run.pending_interviews.is_empty() {
if managed_run.status == RunStatus::Blocked && managed_run.pending_interviews.is_empty()
{
managed_run.status = RunStatus::Running;
}
}
EventBody::InterviewInterrupted(props) => {
managed_run.pending_interviews.remove(&props.question_id);
if managed_run.status == RunStatus::Blocked && managed_run.pending_interviews.is_empty() {
if managed_run.status == RunStatus::Blocked && managed_run.pending_interviews.is_empty()
{
managed_run.status = RunStatus::Running;
}
}