floxide-redis 3.2.2

Redis implementation for Floxide distributed workflow system
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
27
28
29
30
31
32
33
34
35

mod helpers;

use chrono::Utc;
use floxide_core::distributed::{ErrorStore, WorkflowError};
use floxide_redis::{RedisClient, RedisConfig, RedisErrorStore};

#[tokio::test]
async fn test_error_store_roundtrip() {
    helpers::init_tracing();
    let mut redis = helpers::TestRedis::start().await;
    let config = RedisConfig::new(redis.redis_url());
    let client = RedisClient::new(config).await.expect("redis client");
    let store = RedisErrorStore::new(client);

    let run_id = "run1";
    let error = WorkflowError {
        work_item: "item1".to_string(),
        error: "something went wrong".to_string(),
        attempt: 1,
        timestamp: Utc::now(),
    };

    // Record
    store
        .record_error(run_id, error.clone())
        .await
        .expect("record");
    // Get
    let got = store.get_errors(run_id).await.expect("get");
    assert_eq!(got.len(), 1);
    assert_eq!(got[0].work_item, "item1");
    assert_eq!(got[0].error, "something went wrong");
    tracing::info!(?got, "Error store roundtrip successful");
    redis.cleanup().await;
}