a2d2/src/bus_dataset.py [46:69]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        self.step = int(request['step'])

        self.fetch()
        self.pre_fetch_thread.join()

    def is_open(self):
        return (self.start_ts < self.stop_ts) or self.pre_fetch_thread or self.next_batch
        
    def read(self, query=None):
        self.next_batch=self.dbreader.query(query)

    def fetch(self):
        if self.pre_fetch_thread:
            self.pre_fetch_thread.join()

        self.end_ts = self.start_ts + self.step
        if self.end_ts > self.stop_ts:
            self.end_ts = self.stop_ts

        self.pre_fetch_thread = None
        self.cur_batch=self.next_batch
        self.next_batch=None

        if self.start_ts < self.stop_ts:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



a2d2/src/manifest_dataset.py [49:72]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        self.step = int(request['step'])

        self.fetch()
        self.pre_fetch_thread.join()

    def is_open(self):
        return (self.start_ts < self.stop_ts) or self.pre_fetch_thread or self.next_batch
        
    def read(self, query=None):
        self.next_batch=self.dbreader.query(query)

    def fetch(self):
        if self.pre_fetch_thread:
            self.pre_fetch_thread.join()

        self.end_ts = self.start_ts + self.step
        if self.end_ts > self.stop_ts:
            self.end_ts = self.stop_ts

        self.pre_fetch_thread = None
        self.cur_batch=self.next_batch
        self.next_batch=None

        if self.start_ts < self.stop_ts:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -