subprocess

from subprocess import Popen, PIPE

p = Popen(command, stdout=PIPE, stderr=PIPE, stdin=PIPE)

out, err = p.communicate(input=command_input)

rc = p.wait()

if not ignore_errors and rc != expected_rc:

raise AnsibleModuleError(to_native(err))