log_msg = " rcopy - host {} - command {} ".format(host, " ".join(map(str, args)))
return _retry_rexec(args, log_msg, env = None, retry = retry,
- tmp_known_hosts = tmp_known_hosts,
- blocking = True)
+ tmp_known_hosts = tmp_known_hosts,
+ blocking = True)
def rspawn(command, pidfile,
stdout = '/dev/null',
# we can write up to PIPE_BUF bytes without risk
# blocking. POSIX defines PIPE_BUF >= 512
bytes_written = os.write(proc.stdin.fileno(),
- buffer(input, input_offset, 512))
+ buffer(input, input_offset, 512))
input_offset += bytes_written
if input_offset >= len(input):