parameters: (self)
return_statement: return self.res_queue.get(timeout=30)
docstring: Get function for worker result queue. Block with timeout.
docstring_summary: Get function for worker result queue. Block with timeout.
docstring_tokens: Get function for worker result queue . Block with timeout .
function: def get(self):
          """
          Get function for worker result queue. Block with timeout.
          """
          # Relax 10s to 30s, since it sometimes will cause "Generator worker process timeout"
          # when we run too many iterators with infinite epoch(num_epoch=-1)
          return self.res_queue.get(timeout=30)
function_tokens: def get ( self ) : # Relax 10s to 30s, since it sometimes will cause "Generator worker process timeout" # when we run too many iterators with infinite epoch(num_epoch=-1) return self . res_queue . get ( timeout = 30 )