'Determines if we are required and can do pipelining'

def _is_pipelining_enabled(self, module_style, wrap_async=False):

    for condition in [self._connection.has_pipelining, (self._play_context.pipelining or self._connection.always_pipeline_modules), (module_style == 'new'), (not C.DEFAULT_KEEP_REMOTE_FILES), (not wrap_async), (self._play_context.become_method != 'su')]:
        if (not condition):
            return False
    return True
