This test verifies that memory:// backend state is shared over multiple threads
(self)
| 36 | CacheBackend(backend=None, app=self.app) |
| 37 | |
| 38 | def test_memory_client_is_shared(self): |
| 39 | """This test verifies that memory:// backend state is shared over multiple threads""" |
| 40 | from threading import Thread |
| 41 | t = Thread( |
| 42 | target=lambda: CacheBackend(backend='memory://', app=self.app).set('test', 12345) |
| 43 | ) |
| 44 | t.start() |
| 45 | t.join() |
| 46 | assert self.tb.client.get('test') == 12345 |
| 47 | |
| 48 | def test_mark_as_done(self): |
| 49 | assert self.tb.get_state(self.tid) == states.PENDING |