(self, func)
| 112 | LOGGER.exception('Failed to process message ' + text) |
| 113 | |
| 114 | def _start_task(self, func): |
| 115 | future = tornado.ioloop.IOLoop.current().run_in_executor( |
| 116 | executor=self._executor, |
| 117 | func=func) |
| 118 | |
| 119 | return future |
| 120 | |
| 121 | def _set_parameter_value(self, parameter, value, client_state_version): |
| 122 | self._latest_client_state_version = client_state_version |
no outgoing calls
no test coverage detected