@@ -21,8 +21,8 Thread = threading.Thread | |||||
21 | # except: |
|
21 | # except: | |
22 | from time import sleep |
|
22 | from time import sleep | |
23 |
|
23 | |||
24 | from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation |
|
24 | from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation, MPDecorator | |
25 |
|
25 | @MPDecorator | ||
26 | class Remote(Thread): |
|
26 | class Remote(Thread): | |
27 | """ |
|
27 | """ | |
28 | Remote is a parent class used to define the behaviour of FTP and SSH class. These clases are |
|
28 | Remote is a parent class used to define the behaviour of FTP and SSH class. These clases are | |
@@ -572,7 +572,7 class SSHClient(Remote): | |||||
572 | command = 'chmod 775 %s' %remotefile |
|
572 | command = 'chmod 775 %s' %remotefile | |
573 |
|
573 | |||
574 | return self.__execute(command) |
|
574 | return self.__execute(command) | |
575 |
|
575 | @MPDecorator | ||
576 | class SendToServer(ProcessingUnit): |
|
576 | class SendToServer(ProcessingUnit): | |
577 |
|
577 | |||
578 | def __init__(self, **kwargs): |
|
578 | def __init__(self, **kwargs): | |
@@ -599,7 +599,7 class SendToServer(ProcessingUnit): | |||||
599 | raise ValueError("%s has been chosen as remote access protocol but it is not valid" %protocol) |
|
599 | raise ValueError("%s has been chosen as remote access protocol but it is not valid" %protocol) | |
600 |
|
600 | |||
601 | self.clientObj.start() |
|
601 | self.clientObj.start() | |
602 |
|
602 | print("ftp setup complete") | ||
603 | def findFiles(self): |
|
603 | def findFiles(self): | |
604 |
|
604 | |||
605 | if not type(self.localfolder) == list: |
|
605 | if not type(self.localfolder) == list: |
General Comments 0
You need to be logged in to leave comments.
Login now