foxtive-worker 0.2.0

Foxtive Worker - Background worker framework for message processing
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

import re

files = ['integration_tests.rs', 'concurrency_tests.rs']

for filename in files:
    with open(filename, 'r') as f:
        content = f.read()
    
    # Fix multi-line WorkerPool::with_concurrency calls
    pattern = r'(WorkerPool::with_concurrency\(\s*"[^"]+",\s*LoadBalancingStrategy::\w+,\s*\d+,)(\s*\))'
    replacement = r'\1\n        Arc::new(NoOpMetrics),\2'
    content = re.sub(pattern, replacement, content)
    
    with open(filename, 'w') as f:
        f.write(content)

print("Fixed test files")