btfxwss/queue_processor.py
def update_timestamps(self, chan_id, ts):
        """Updates the timestamp for the given channel id.

        :param chan_id:
        :param ts:
        :return:
        """
        try:
            self.last_update[chan_id] = ts
        except KeyError:
            self.log.warning("Attempted ts update of channel %s, but channel "
                             "not present anymore.",
                             self.channel_directory[chan_id])
def update_timestamps(self, chan_id, ts):
        try:
            self.last_update[chan_id] = ts
        except KeyError:
            self.log.warning("Attempted ts update of channel %s, but channel "
                             "not present anymore.",
                             self.channel_directory[chan_id])
def update_timestamps ( self , chan_id , ts ) : try : self . last_update [ chan_id ] = ts except KeyError : self . log . warning ( "Attempted ts update of channel %s, but channel " "not present anymore." , self . channel_directory [ chan_id ] )
Updates the timestamp for the given channel id.

        :param chan_id:
        :param ts:
        :return:
Updates the timestamp for the given channel id .