(self, q)
| 83 | assert q.is_active("/a/b.mkv") is True |
| 84 | |
| 85 | def test_active_while_processing(self, q): |
| 86 | q.put(_task("/a/b.mkv")) |
| 87 | q.get() |
| 88 | assert q.is_active("/a/b.mkv") is True |
| 89 | |
| 90 | def test_not_active_when_absent(self, q): |
| 91 | assert q.is_active("/a/b.mkv") is False |