(self, sensors_partitioner, single_sensor_mode=False)
| 32 | |
| 33 | class SensorContainerManager(object): |
| 34 | def __init__(self, sensors_partitioner, single_sensor_mode=False): |
| 35 | if not sensors_partitioner: |
| 36 | raise ValueError("sensors_partitioner should be non-None.") |
| 37 | |
| 38 | self._sensors_partitioner = sensors_partitioner |
| 39 | self._single_sensor_mode = single_sensor_mode |
| 40 | |
| 41 | self._sensor_container = None |
| 42 | self._container_thread = None |
| 43 | |
| 44 | self._sensors_watcher = SensorWatcher( |
| 45 | create_handler=self._handle_create_sensor, |
| 46 | update_handler=self._handle_update_sensor, |
| 47 | delete_handler=self._handle_delete_sensor, |
| 48 | queue_suffix="sensor_container", |
| 49 | ) |
| 50 | |
| 51 | def run_sensors(self): |
| 52 | """ |
nothing calls this directly
no test coverage detected