lazycelery 0.8.3

A terminal UI for monitoring and managing Celery workers and tasks, inspired by lazydocker/lazygit
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

//! Result backend trait for storing task results
//!
//! This module provides a trait for result backends that store task results,
//! tracebacks, and metadata. This is separate from the broker which handles
//! message routing.

use async_trait::async_trait;

use crate::error::BrokerError;
use crate::models::Task;

/// Result backend trait for storing task results
///
/// Result backends store the results of tasks after they complete,
/// including success results, failure tracebacks, and timing information.
#[async_trait]
#[allow(dead_code)]
pub trait ResultBackend: Send + Sync {
    /// Get a task result by ID
    async fn get_task_result(&self, task_id: &str) -> Result<Option<Task>, BrokerError>;

    /// Connect to the result backend
    async fn connect(url: &str) -> Result<Self, BrokerError>
    where
        Self: Sized;
}