(self, task_id)
| 158 | self._consume_from(task_id) |
| 159 | |
| 160 | def _consume_from(self, task_id): |
| 161 | key = self._get_key_for_task(task_id) |
| 162 | if key not in self.subscribed_to: |
| 163 | self.subscribed_to.add(key) |
| 164 | with self.reconnect_on_error(): |
| 165 | self._pubsub.subscribe(key) |
| 166 | |
| 167 | def cancel_for(self, task_id): |
| 168 | key = self._get_key_for_task(task_id) |
no test coverage detected