| 63 | |
| 64 | |
| 65 | class TestMarkDone: |
| 66 | def test_mark_done_allows_requeue(self, q): |
| 67 | task = _task("/a/b.mkv") |
| 68 | q.put(task) |
| 69 | popped = q.get() |
| 70 | q.mark_done(popped) |
| 71 | assert q.put(task) is True |
| 72 | |
| 73 | def test_without_mark_done_blocks_requeue(self, q): |
| 74 | task = _task("/a/b.mkv") |
| 75 | q.put(task) |
| 76 | q.get() # now _processing, but not marked done |
| 77 | assert q.put(task) is False |
| 78 | |
| 79 | |
| 80 | class TestIsActive: |
nothing calls this directly
no outgoing calls
no test coverage detected