def get_pipe(self):
        """
            Returns a list that maps the input of the pipe to an elasticsearch object.
            Will call id_to_object if it cannot serialize the data from json.
        """
        lines = []
        for line in sys.stdin:
            try:
                lines.append(self.line_to_object(line.strip()))
            except ValueError:
                pass
            except KeyError:
                pass
        return lines
def get_pipe(self):
        """
            Returns a list that maps the input of the pipe to an elasticsearch object.
            Will call id_to_object if it cannot serialize the data from json.
        """
        lines = []
        for line in sys.stdin:
            try:
                lines.append(self.line_to_object(line.strip()))
            except ValueError:
                pass
            except KeyError:
                pass
        return lines
def get_pipe ( self ) : lines = [ ] for line in sys . stdin : try : lines . append ( self . line_to_object ( line . strip ( ) ) ) except ValueError : pass except KeyError : pass return lines
Returns a list that maps the input of the pipe to an elasticsearch object.
            Will call id_to_object if it cannot serialize the data from json.
Returns a list that maps the input of the pipe to an elasticsearch object . Will call id_to_object if it cannot serialize the data from json .