Coverage for agentos/queue.py: 0%

1from dataclasses import dataclass 

2from enum import Enum 

3 

4 

5class TaskState(Enum): 

6 PENDING = "pending" 

7 

8 

9class TaskPriority(Enum): 

10 HIGH = 1 

11 MEDIUM = 5 

12 LOW = 10 

13 

14 

15@dataclass 

16class TaskQueue: 

17 def submit(self, fn, priority=TaskPriority.MEDIUM): 

18 pass 

19 

20 

21class RateLimitStrategy(Enum): 

22 SLIDING_WINDOW = "sliding_window" 

23 

24 

25@dataclass 

26class RateLimitConfig: 

27 max_rps: float = 10.0 

28 

29 

30class RateLimiter: 

31 def __init__(self, config=None): 

32 pass