(self)
return {name: value for name, value in zip(names, queue_lengths)}
Measure the observation queue sizes (redis llen).
Measure the observation queue sizes (redis llen).
Measure the observation queue sizes ( redis llen ) .
def get_queue_sizes(self):
        """Measure the observation queue sizes (redis llen)."""
        names = list(self.task.app.all_queues.keys())
        with self.task.redis_client.pipeline() as pipe:
            for name in names:
                pipe.llen(name)
            queue_lengths = pipe.execute()
        return {name: value for name, value in zip(names, queue_lengths)}
def get_queue_sizes ( self ) : names = list ( self . task . app . all_queues . keys ( ) ) with self . task . redis_client . pipeline ( ) as pipe : for name in names : pipe . llen ( name ) queue_lengths = pipe . execute ( ) return { name : value for name , value in zip ( names , queue_lengths ) }