fix send_pickle

erdos-project · Mar 17, 2022 · 42bbda9 · 42bbda9
1 parent ac024de
commit 42bbda9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/pylot/drivers/carla_camera_driver_operator.py b/pylot/drivers/carla_camera_driver_operator.py
@@ -81,8 +81,8 @@ def release_data(self, timestamp):
             self._logger.debug("@{}: {} releasing sensor data".format(
                 timestamp, self.config.name))
             watermark_msg = erdos.WatermarkMessage(timestamp)
-            self._camera_stream.send_pickled(timestamp,
-                                             self._pickled_messages[timestamp])
+            msg = pickle.loads(self._pickled_messages[timestamp])
+            self._camera_stream.send(msg)
             # Note: The operator is set not to automatically propagate
             # watermark messages received on input streams. Thus, we can
             # issue watermarks only after the simulator callback is invoked.

diff --git a/pylot/drivers/carla_lidar_driver_operator.py b/pylot/drivers/carla_lidar_driver_operator.py
@@ -71,8 +71,8 @@ def release_data(self, timestamp):
             self._release_data = True
         else:
             watermark_msg = erdos.WatermarkMessage(timestamp)
-            self._lidar_stream.send_pickled(timestamp,
-                                            self._pickled_messages[timestamp])
+            msg = pickle.loads(self._pickled_messages[timestamp])
+            self._lidar_stream.send(msg)
             # Note: The operator is set not to automatically propagate
             # watermark messages received on input streams. Thus, we can
             # issue watermarks only after the simulator callback is invoked.