def _pipeline(self, name):
if name == self.connection_name:<EOL><INDENT>return self<EOL><DEDENT>try:<EOL><INDENT>return self._pipelines[name]<EOL><DEDENT>except KeyError:<EOL><INDENT>pipe = Pipeline(name=name, autoexec=True)<EOL>self._pipelines[name] = pipe<EOL>return pipe<EOL><DEDENT>
Don't call this function directly.
Used by the NestedPipeline class when it executes.
:param name:
:return: