Skip to content

Commit f4c774e

Browse files
committed
fixed key not exist error
1 parent 3e15b7f commit f4c774e

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

qiniu/services/storage/uploader.py

+10-2
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,9 @@ def __init__(self, up_token, key, input_stream, data_size, params, mime_type,
131131
self.upload_progress_recorder = upload_progress_recorder or UploadProgressRecorder()
132132
self.modify_time = modify_time or time.time()
133133

134+
print(self.modify_time)
135+
print(modify_time)
136+
134137
def record_upload_progress(self, offset):
135138
record_data = {
136139
'size': self.size,
@@ -139,15 +142,20 @@ def record_upload_progress(self, offset):
139142
}
140143
if self.modify_time:
141144
record_data['modify_time'] = self.modify_time
145+
146+
print(record_data)
142147
self.upload_progress_recorder.set_upload_record(self.key, record_data)
143148

144149
def recovery_from_record(self):
145150
record = self.upload_progress_recorder.get_upload_record(self.key)
146151
if not record:
147152
return 0
148153

149-
if not record['modify_time'] or record['size'] != self.size or \
150-
record['modify_time'] != self.modify_time:
154+
try:
155+
if not record['modify_time'] or record['size'] != self.size or \
156+
record['modify_time'] != self.modify_time:
157+
return 0
158+
except KeyError:
151159
return 0
152160

153161
self.blockStatus = [{'ctx': ctx} for ctx in record['contexts']]

0 commit comments

Comments
 (0)