def __write_ros_msg_to_bag()

in a2d2/src/rosbag_producer.py [0:0]

• 10 lines of code
• 6 McCabe index (conditional complexity)

    def __write_ros_msg_to_bag(self, topic=None, msg=None, ts=None, s3_client=None, flush=False):

        if not self.bag:
            self.__open_bag()
        self.bag.write(topic, msg, ts)
                
        if not flush and topic != self.bus_topic:
            self.round_robin.append(topic)
            if self.multipart:
                self.msg_count += 1
                if self.msg_count % self.chunk_count == 0:
                    self.__close_bag(s3_client=s3_client)