Show More
@@ -603,14 +603,14 b' class SSHLauncher(LocalProcessLauncher):' | |||
|
603 | 603 | check_output(self.scp_cmd + [local, remote]) |
|
604 | 604 | |
|
605 | 605 | def send_files(self): |
|
606 | """send our files""" | |
|
607 |
if not self.send |
|
|
606 | """send our files (called before start)""" | |
|
607 | if not self.to_send: | |
|
608 | 608 | return |
|
609 | 609 | for local_file, remote_file in self.to_send: |
|
610 | 610 | self._send_file(local_file, remote_file) |
|
611 | 611 | |
|
612 | 612 | def _fetch_file(self, remote, local): |
|
613 |
""" |
|
|
613 | """fetch a single file""" | |
|
614 | 614 | full_remote = "%s:%s" % (self.location, remote) |
|
615 | 615 | self.log.info("fetching %s from %s", local, full_remote) |
|
616 | 616 | for i in range(10): |
@@ -618,15 +618,15 b' class SSHLauncher(LocalProcessLauncher):' | |||
|
618 | 618 | check = check_output(self.ssh_cmd + self.ssh_args + \ |
|
619 | 619 | [self.location, 'test -e', remote, "&& echo 'yes' || echo 'no'"]) |
|
620 | 620 | check = check.strip() |
|
621 |
if check |
|
|
621 | if check == 'no': | |
|
622 | 622 | time.sleep(1) |
|
623 |
elif check |
|
|
623 | elif check == 'yes': | |
|
624 | 624 | break |
|
625 | 625 | check_output(self.scp_cmd + [full_remote, local]) |
|
626 | 626 | |
|
627 | 627 | def fetch_files(self): |
|
628 | """override in subclass""" | |
|
629 |
if not self.fetch |
|
|
628 | """fetch remote files (called after start)""" | |
|
629 | if not self.to_fetch: | |
|
630 | 630 | return |
|
631 | 631 | for remote_file, local_file in self.to_fetch: |
|
632 | 632 | self._fetch_file(remote_file, local_file) |
General Comments 0
You need to be logged in to leave comments.
Login now