Partition assignor did not complete assignor due to error.
(
self, assignor: PartitionAssignorT, state: Dict, exc: BaseException
)
| 171 | ) |
| 172 | |
| 173 | def on_assignment_error( |
| 174 | self, assignor: PartitionAssignorT, state: Dict, exc: BaseException |
| 175 | ) -> None: |
| 176 | """Partition assignor did not complete assignor due to error.""" |
| 177 | super().on_assignment_error(assignor, state, exc) |
| 178 | self.client.incr("assignments_error", rate=self.rate) |
| 179 | self.client.timing( |
| 180 | "assignment_latency", self.ms_since(state["time_start"]), rate=self.rate |
| 181 | ) |
| 182 | |
| 183 | def on_assignment_completed( |
| 184 | self, assignor: PartitionAssignorT, state: Dict |