ralph-agent-loop 0.4.0

A Rust CLI for managing AI agent loops with a structured JSON task queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

//! Webhook delivery worker thread loop.

use crossbeam_channel::{Receiver, Sender};
use std::sync::Weak;

use super::types::{DeliveryTask, ScheduledRetry};
use crate::webhook::diagnostics;
use crate::webhook::worker::delivery::handle_delivery_task;

pub(super) fn worker_loop(
    ready_receiver: Receiver<DeliveryTask>,
    retry_sender: Weak<Sender<ScheduledRetry>>,
) {
    while let Ok(task) = ready_receiver.recv() {
        diagnostics::note_queue_dequeue();
        handle_delivery_task(task, &retry_sender);
    }
}