parameters: (self)
docstring: Streams all output data (e.g. STDOUT/STDERR) to the
          client from the agent.
docstring_summary: Streams all output data (e.g. STDOUT/STDERR) to the
          client from the agent.
docstring_tokens: Streams all output data ( e . g . STDOUT / STDERR ) to the client from the agent .
function: def _attach_container_output(self):
          """
          Streams all output data (e.g. STDOUT/STDERR) to the
          client from the agent.
          """
  
          message = {
              'type': 'ATTACH_CONTAINER_OUTPUT',
              'attach_container_output': {
                  'container_id': self.container_id}}
  
          req_extra_args = {
              'stream': True,
              'verify': self.config.agent_ssl_verify(),
              'additional_headers': {
                  'Content-Type': 'application/json',
                  'Accept': 'application/recordio',
                  'Message-Accept': 'application/json'}}
  
          try:
              resource = mesos.http.Resource(self.agent_url)
              response = resource.request(
                  mesos.http.METHOD_POST,
                  data=json.dumps(message),
                  retry=False,
                  timeout=None,
                  auth=self.config.authentication_header(),
                  **req_extra_args)
          except MesosHTTPException as e:
              text = "I/O switchboard server was disabled for this container"
              if e.response.status_code == 500 and e.response.text == text:
                  raise CLIException("Unable to attach to a task"
                                     " launched without a TTY")
              raise e
  
          self._process_output_stream(response)
function_tokens: def _attach_container_output ( self ) : message = { 'type' : 'ATTACH_CONTAINER_OUTPUT' , 'attach_container_output' : { 'container_id' : self . container_id } } req_extra_args = { 'stream' : True , 'verify' : self . config . agent_ssl_verify ( ) , 'additional_headers' : { 'Content-Type' : 'application/json' , 'Accept' : 'application/recordio' , 'Message-Accept' : 'application/json' } } try : resource = mesos . http . Resource ( self . agent_url ) response = resource . request ( mesos . http . METHOD_POST , data = json . dumps ( message ) , retry = False , timeout = None , auth = self . config . authentication_header ( ) , * * req_extra_args ) except MesosHTTPException as e : text = "I/O switchboard server was disabled for this container" if e . response . status_code == 500 and e . response . text == text : raise CLIException ( "Unable to attach to a task" " launched without a TTY" ) raise e self . _process_output_stream ( response )