snerd-rust 0.2.2

A lightweight, robust, asynchronous background job queue and persistence engine built for high-performance applications.
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

with open('tests/integration_test.rs', 'r') as f:
    content = f.read()

# Replace missing imports by adding them at the top
imports = """
use std::sync::Mutex;
use chrono::Utc;
use snerd_rust::rate_limiter::RateLimiter;
use tempfile::tempdir;
"""
if "use std::sync::Mutex;" not in content:
    content = imports + content

# Fix the test handler
old_handler = """        .register_task_handler("cron-task", move |_| {
            let e = exec_clone.clone();
            async move {
                *e.lock().unwrap() = true;
                Ok(())
            }
        })"""
new_handler = """        .register_task_handler("cron-task", move |_data| {
            let e = exec_clone.clone();
            *e.lock().unwrap() = true;
            Ok(())
        })"""

content = content.replace(old_handler, new_handler)

with open('tests/integration_test.rs', 'w') as f:
    f.write(content)