(self)
| 126 | self._connection.close() |
| 127 | |
| 128 | def on_after_fork(self): |
| 129 | self._consumer = None |
| 130 | if self._connection is not None: |
| 131 | self._connection.collect() |
| 132 | self._connection = None |
| 133 | |
| 134 | def consume_from(self, task_id): |
| 135 | if self._consumer is None: |