(self, tiger, queue_sample_tasks)
| 101 | assert tiger.get_total_queue_size("default") == 3 |
| 102 | |
| 103 | def test_get_queue_sizes(self, tiger, queue_sample_tasks): |
| 104 | assert tiger.get_queue_sizes("default") == { |
| 105 | "active": 0, |
| 106 | "queued": 2, |
| 107 | "scheduled": 1, |
| 108 | } |
| 109 | assert tiger.get_queue_sizes("other") == { |
| 110 | "active": 0, |
| 111 | "queued": 1, |
| 112 | "scheduled": 0, |
| 113 | } |
| 114 | |
| 115 | def test_get_sizes_for_queues_and_states(self, tiger, queue_sample_tasks): |
| 116 | assert tiger.get_sizes_for_queues_and_states( |
nothing calls this directly
no test coverage detected