...
|
...
|
@@ -838,33 +838,16 @@ def cmd_sync_remote2local(args):
|
838
|
838
|
except S3DownloadError, e:
|
839
|
839
|
error(u"%s: download failed too many times. Skipping that file." % file)
|
840
|
840
|
continue
|
841
|
|
-<<<<<<< HEAD
|
842
|
841
|
speed_fmt = formatSize(response["speed"], human_readable = True, floating_point = True)
|
843
|
842
|
if not Config().progress_meter:
|
844
|
843
|
output(u"File '%s' stored as '%s' (%d bytes in %0.1f seconds, %0.2f %sB/s) %s" %
|
845
|
844
|
(uri, unicodise(dst_file), response["size"], response["elapsed"], speed_fmt[0], speed_fmt[1],
|
846
|
845
|
seq_label))
|
847
|
846
|
total_size += response["size"]
|
|
847
|
+ if Config().delete_after_fetch:
|
|
848
|
+ s3.object_delete(uri)
|
|
849
|
+ output(u"File '%s' removed after syncing" % (uri))
|
848
|
850
|
return seq, total_size
|
849
|
|
-=======
|
850
|
|
- # We have to keep repeating this call because
|
851
|
|
- # Python 2.4 doesn't support try/except/finally
|
852
|
|
- # construction :-(
|
853
|
|
- try: dst_stream.close()
|
854
|
|
- except: pass
|
855
|
|
- except S3DownloadError, e:
|
856
|
|
- error(u"%s: download failed too many times. Skipping that file." % file)
|
857
|
|
- continue
|
858
|
|
- speed_fmt = formatSize(response["speed"], human_readable = True, floating_point = True)
|
859
|
|
- if not Config().progress_meter:
|
860
|
|
- output(u"File '%s' stored as '%s' (%d bytes in %0.1f seconds, %0.2f %sB/s) %s" %
|
861
|
|
- (uri, unicodise(dst_file), response["size"], response["elapsed"], speed_fmt[0], speed_fmt[1],
|
862
|
|
- seq_label))
|
863
|
|
- if Config().delete_after_fetch:
|
864
|
|
- s3.object_delete(uri)
|
865
|
|
- output(u"File '%s' removed after syncing" % (uri))
|
866
|
|
- total_size += response["size"]
|
867
|
|
->>>>>>> nicjansma/master
|
868
|
851
|
|
869
|
852
|
total_size = 0
|
870
|
853
|
total_elapsed = 0.0
|
...
|
...
|
@@ -1705,13 +1688,10 @@ def main():
|
1705
|
1705
|
|
1706
|
1706
|
optparser.add_option( "--delete-removed", dest="delete_removed", action="store_true", help="Delete remote objects with no corresponding local file [sync]")
|
1707
|
1707
|
optparser.add_option( "--no-delete-removed", dest="delete_removed", action="store_false", help="Don't delete remote objects.")
|
1708
|
|
-<<<<<<< HEAD
|
1709
|
1708
|
optparser.add_option( "--delete-after", dest="delete_after", action="store_true", help="Perform deletes after new uploads [sync]")
|
1710
|
1709
|
optparser.add_option( "--delay-updates", dest="delay_updates", action="store_true", help="Put all updated files into place at end [sync]")
|
1711
|
1710
|
optparser.add_option( "--add-destination", dest="additional_destinations", action="append", help="Additional destination for parallel uploads, in addition to last arg. May be repeated.")
|
1712
|
|
-=======
|
1713
|
1711
|
optparser.add_option( "--delete-after-fetch", dest="delete_after_fetch", action="store_true", help="Delete remote objects after fetching to local file (only for [get] and [sync] commands).")
|
1714
|
|
->>>>>>> nicjansma/master
|
1715
|
1712
|
optparser.add_option("-p", "--preserve", dest="preserve_attrs", action="store_true", help="Preserve filesystem attributes (mode, ownership, timestamps). Default for [sync] command.")
|
1716
|
1713
|
optparser.add_option( "--no-preserve", dest="preserve_attrs", action="store_false", help="Don't store FS attributes")
|
1717
|
1714
|
optparser.add_option( "--exclude", dest="exclude", action="append", metavar="GLOB", help="Filenames and paths matching GLOB will be excluded from sync")
|