|
|
@@ -107,7 +107,10 @@ def plugged_in(dev, source_dir, dest_dir, ftp):
|
|
|
# Beam files to FTP
|
|
|
for up_file in joined_files:
|
|
|
logger.info('Uploading %s to %s', up_file, ftp['host'])
|
|
|
- execute('ncftpput -u %s -p %s %s %s %s' % (ftp['user'], ftp['password'], ftp['host'], ftp['path'], up_file))
|
|
|
+ output = execute('ncftpput -u %s -p %s %s %s %s' % (ftp['user'], ftp['password'], ftp['host'], ftp['path'], up_file))
|
|
|
+ if output != None:
|
|
|
+ logger.info('Removing %s', up_file)
|
|
|
+ os.remove(up_file)
|
|
|
|
|
|
logger.info('Done')
|
|
|
|
