Index: download_from_google_storage.py |
diff --git a/download_from_google_storage.py b/download_from_google_storage.py |
index 8370515e6a15879c3ddf5c1e8693efeb595a8ccd..ffdd4ee97893ee7fb6e25e3a9cdc3be01268f838 100755 |
--- a/download_from_google_storage.py |
+++ b/download_from_google_storage.py |
@@ -236,8 +236,13 @@ def _downloader_worker_thread(thread_num, q, force, base_url, |
file_url, output_filename))) |
continue |
# Fetch the file. |
- out_q.put('%d> Downloading %s...' % ( |
- thread_num, output_filename)) |
+ out_q.put('%d> Downloading %s...' % (thread_num, output_filename)) |
+ try: |
+ os.remove(output_filename) # Delete the file if it exists already. |
+ except OSError: |
+ if os.path.exists(output_filename): |
+ out_q.put('%d> Warning: deleting %s failed.' % ( |
+ thread_num, output_filename)) |
code, _, err = gsutil.check_call('cp', '-q', file_url, output_filename) |
if code != 0: |
out_q.put('%d> %s' % (thread_num, err)) |