| 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))
|
|
|