(self)
| 267 | self._sensor_instance = self._get_sensor_instance() |
| 268 | |
| 269 | def run(self): |
| 270 | atexit.register(self.stop) |
| 271 | |
| 272 | self._trigger_watcher.start() |
| 273 | self._logger.info("Watcher started") |
| 274 | |
| 275 | self._logger.info("Running sensor initialization code") |
| 276 | self._sensor_instance.setup() |
| 277 | |
| 278 | if self._poll_interval: |
| 279 | message = "Running sensor in active mode (poll interval=%ss)" % ( |
| 280 | self._poll_interval |
| 281 | ) |
| 282 | else: |
| 283 | message = "Running sensor in passive mode" |
| 284 | |
| 285 | self._logger.info(message) |
| 286 | |
| 287 | try: |
| 288 | self._sensor_instance.run() |
| 289 | except Exception as e: |
| 290 | # Include traceback |
| 291 | msg = 'Sensor "%s" run method raised an exception: %s.' % ( |
| 292 | self._class_name, |
| 293 | six.text_type(e), |
| 294 | ) |
| 295 | self._logger.warning(msg, exc_info=True) |
| 296 | raise Exception(msg) |
| 297 | |
| 298 | def stop(self): |
| 299 | # Stop watcher |
no test coverage detected