def update_keys(self):
        """
        Update the redis keys to listen for new jobs priorities.
        """
        self.keys = self.queue_model.get_waiting_keys(self.queues)

        if not self.keys:
            self.log('No queues yet', level='warning')
        self.last_update_keys = datetime.utcnow()
def update_keys ( self ) : self . keys = self . queue_model . get_waiting_keys ( self . queues ) if not self . keys : self . log ( 'No queues yet' , level = 'warning' ) self . last_update_keys = datetime . utcnow ( )
Update the redis keys to listen for new jobs priorities.