Coverage for agentos/queue.py: 0%
12 statements
« prev ^ index » next coverage.py v7.14.3, created at 2026-07-02 09:59 +0800
1from dataclasses import dataclass; from enum import Enum
2class TaskState(Enum): PENDING='pending'
3class TaskPriority(Enum): HIGH=1; MEDIUM=5; LOW=10
4@dataclass
5class TaskQueue:
6 def submit(self, fn, priority=TaskPriority.MEDIUM): pass
7class RateLimitStrategy(Enum): SLIDING_WINDOW='sliding_window'
8@dataclass
9class RateLimitConfig:
10 max_rps: float = 10.0
11class RateLimiter:
12 def __init__(self, config=None): pass