Commit eb43f70 Daniel Thielking
committed
1 parent 102ae23 commit eb43f70 Copy full SHA for eb43f70
File tree 1 file changed +7
-6
lines changed
1 file changed +7
-6
lines changed Original file line number Diff line number Diff line change @@ -89,12 +89,13 @@ def run(self):
89
89
self .key = q .get ()
90
90
self .dest_obj = self .s3 .Object (self .bucket , self .key )
91
91
try :
92
- self .copy_source = {'Bucket' : self .bucket , 'Key' : self .key }
93
- self .dest_obj .copy_from (
94
- self .copy_source ,
95
- ExtraArgs = {'StorageClass' : self .storage_class }
96
- )
97
- q .task_done ()
92
+ if self .dest_obj .storage_class != self .storage_class :
93
+ self .copy_source = {'Bucket' : self .bucket , 'Key' : self .key }
94
+ self .dest_obj .copy_from (
95
+ self .copy_source ,
96
+ ExtraArgs = {'StorageClass' : self .storage_class }
97
+ )
98
+ q .task_done ()
98
99
except ConnectionRefusedError as exc :
99
100
logger .error ("To many connections open.\n \
100
101
Put {} back to queue." .format (self .key ))
You can’t perform that action at this time.
0 commit comments