(self)
| 1112 | """ |
| 1113 | |
| 1114 | def test_current_task(self): |
| 1115 | task = Task(self.tiger, verify_current_task) |
| 1116 | task.delay() |
| 1117 | Worker(self.tiger).run(once=True) |
| 1118 | assert not self.conn.exists("runtime_error") |
| 1119 | assert self.conn.get("task_id") == task.id |
| 1120 | |
| 1121 | def test_current_tasks(self): |
| 1122 | task1 = Task(self.tiger, verify_current_tasks) |