Restart workers patch with fixes

modules/cluster_estimation/cluster_estimation_worker.py

@@ -84,7 +84,9 @@ def cluster_estimation_worker(
 
         for single_input in input_data:
             if not isinstance(single_input, detection_in_world.DetectionInWorld):
-                local_logger.warning(f"Skipping unexpected input: {input}")
+                local_logger.warning(
+                    f"Skipping unexpected input: {input_data}, because of unexpected value: {single_input}"
+                )
                 is_invalid = True
                 break
 

modules/communications/communications_worker.py

@@ -70,7 +70,9 @@ def communications_worker(
 
         for single_input in input_data:
             if not isinstance(single_input, object_in_world.ObjectInWorld):
-                local_logger.warning(f"Skipping unexpected input: {input}")
+                local_logger.warning(
+                    f"Skipping unexpected input: {input_data}, because of unexpected value: {single_input}"
+                )
                 is_invalid = True
                 break
 

modules/detect_target/detect_target_worker.py

@@ -69,7 +69,7 @@ def detect_target_worker(
             break
 
         if not isinstance(input_data, image_and_time.ImageAndTime):
-            local_logger.warning(f"Skipping unexpected input: {input}")
+            local_logger.warning(f"Skipping unexpected input: {input_data}")
             continue
 
         result, value = detector.run(input_data)

modules/geolocation/geolocation_worker.py

@@ -60,7 +60,7 @@ def geolocation_worker(
             break
 
         if not isinstance(input_data, merged_odometry_detections.MergedOdometryDetections):
-            local_logger.warning(f"Skipping unexpected input: {input}")
+            local_logger.warning(f"Skipping unexpected input: {input_data}")
             continue
 
         result, value = locator.run(input_data)

utilities/workers/worker_manager.py

@@ -244,11 +244,4 @@ def check_and_restart_dead_workers(self) -> bool:
 
         self.__workers = new_workers
 
-        # Draining the preceding queue ensures that the preceding queue data wasn't what
-        # caused the worker to fail. Draining the succeeding queues is not needed
-        # because a worker that died would not have put bad data into the queue.
-        # input_queues = self.__worker_properties.get_input_queues()
-        # for queue in input_queues:
-        #     queue.drain_queue()
-
         return True