parameters: (self)
return_statement: return {name: value for name, value in zip(names, queue_lengths)}
docstring: Measure the observation queue sizes (redis llen).
docstring_summary: Measure the observation queue sizes (redis llen).
docstring_tokens: Measure the observation queue sizes ( redis llen ) .
function: 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)}
function_tokens: 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 ) }