Updates

pylot/simulation/carla_operator.py

@@ -84,9 +84,8 @@ def __init__(
         # handle (which is slow).
         self._spectator = self._world.get_spectator()
 
-        if not (self._simulator_version.startswith('0.8')
-                or re.match('0.9.[02-7]', self._simulator_version) is not None
-                or self._simulator_version == '0.9.1'):
+        if not (self._simulator_version.startswith('0.8') or re.match(
+                '0.9.[1-9]$', self._simulator_version) is not None):
             # Any simulator version after 0.9.7.
             # Create a traffic manager to that auto pilot works.
             self._traffic_manager = self._client.get_trafficmanager(

pylot/simulation/perfect_lane_detector_operator.py

@@ -124,3 +124,4 @@ def on_position_update(self, timestamp: Timestamp,
             lanes = []
         output_msg = LanesMessage(pose_msg.timestamp, lanes)
         detected_lane_stream.send(output_msg)
+        detected_lane_stream.send(erdos.WatermarkMessage(pose_msg.timestamp))