import os
import subprocess
-from cStringIO import StringIO
-
from teuthology.parallel import parallel
from teuthology.task import ansible
+from teuthology.exceptions import CommandFailedError
log = logging.getLogger(__name__)
for rem in ctx.cluster.remotes.keys():
if rem.is_vm:
ansible_hosts.add(rem.shortname)
- r = rem.run(args=['test', '-e', '/ceph-qa-ready'],
- stdout=StringIO(), check_status=False)
- if r.returncode != 0:
+ try:
+ rem.sh('test -e /ceph-qa-ready')
+ except CommandFailedError:
p1 = subprocess.Popen(['cat', editinfo],
stdout=subprocess.PIPE)
p2 = subprocess.Popen(