(&mut self)
| 1050 | /// Processes the work queued by [`ComputeController::ready`]. |
| 1051 | #[mz_ore::instrument(level = "debug")] |
| 1052 | pub fn process(&mut self) -> Option<ComputeControllerResponse> { |
| 1053 | // Perform periodic maintenance work. |
| 1054 | if self.maintenance_scheduled { |
| 1055 | self.maintain(); |
| 1056 | self.maintenance_scheduled = false; |
| 1057 | } |
| 1058 | |
| 1059 | // Return a ready response, if any. |
| 1060 | self.stashed_response.take() |
| 1061 | } |
| 1062 | |
| 1063 | #[mz_ore::instrument(level = "debug")] |
| 1064 | fn maintain(&mut self) { |