@@ -135,7 +135,6 @@ def setUp(self):
135
135
self .put_test_object_path = "/put_object_test_py_10MB.txt"
136
136
self .region = "us-west-2"
137
137
self .bucket_name = "aws-crt-canary-bucket"
138
- self .default_file_path = "test/resources/s3_put_object.txt"
139
138
self .timeout = 100 # seconds
140
139
self .num_threads = 0
141
140
self .non_ascii_file_name = "ÉxÅmple.txt" .encode ("utf-8" )
@@ -150,6 +149,7 @@ def setUp(self):
150
149
self .put_body_stream = None
151
150
152
151
self .files = FileCreator ()
152
+ self .temp_put_obj_file_path = self .files .create_file_with_size ("temp_put_obj_10mb" , 10 * MB )
153
153
super ().setUp ()
154
154
155
155
def tearDown (self ):
@@ -223,7 +223,7 @@ def test_get_object(self):
223
223
self ._test_s3_put_get_object (request , S3RequestType .GET_OBJECT )
224
224
225
225
def test_put_object (self ):
226
- request = self ._put_object_request (self .default_file_path )
226
+ request = self ._put_object_request (self .temp_put_obj_file_path )
227
227
self ._test_s3_put_get_object (request , S3RequestType .PUT_OBJECT )
228
228
self .put_body_stream .close ()
229
229
@@ -288,15 +288,15 @@ def test_get_object_file_object(self):
288
288
os .remove (file .name )
289
289
290
290
def test_put_object_file_object (self ):
291
- request = self ._put_object_request (self .default_file_path )
291
+ request = self ._put_object_request (self .temp_put_obj_file_path )
292
292
request_type = S3RequestType .PUT_OBJECT
293
293
# close the stream, to test if the C FILE pointer as the input stream working well.
294
294
self .put_body_stream .close ()
295
295
s3_client = s3_client_new (False , self .region , 5 * MB )
296
296
s3_request = s3_client .make_request (
297
297
request = request ,
298
298
type = request_type ,
299
- send_filepath = self .default_file_path ,
299
+ send_filepath = self .temp_put_obj_file_path ,
300
300
on_headers = self ._on_request_headers ,
301
301
on_progress = self ._on_progress )
302
302
finished_future = s3_request .finished_future
@@ -434,7 +434,7 @@ def test_put_object_quick_cancel(self):
434
434
return self ._put_object_cancel_helper (False )
435
435
436
436
def test_multipart_upload_with_invalid_request (self ):
437
- request = self ._put_object_request (self .default_file_path )
437
+ request = self ._put_object_request (self .temp_put_obj_file_path )
438
438
request .headers .set ("Content-MD5" , "something" )
439
439
self ._test_s3_put_get_object (request , S3RequestType .PUT_OBJECT , "AWS_ERROR_S3_INVALID_RESPONSE_STATUS" )
440
440
self .put_body_stream .close ()
0 commit comments