@@ -83,7 +83,7 @@ def test_exec(config, ssh_con):
83
83
config .user_count = 1
84
84
user_info = s3lib .create_users (config .user_count )
85
85
user_info = user_info [0 ]
86
- auth = Auth (user_info , ssh_con , ssl = config .ssl )
86
+ auth = Auth (user_info , ssh_con , ssl = config .ssl , haproxy = config . haproxy )
87
87
rgw_conn = auth .do_auth ()
88
88
verification = True
89
89
if config .test_with_bucket_index_shards :
@@ -310,7 +310,7 @@ def test_exec(config, ssh_con):
310
310
log .info ("Create new user and change bucket ownership" )
311
311
new_user = s3lib .create_users (1 )
312
312
new_user = new_user [0 ]
313
- new_auth = Auth (new_user , ssh_con , ssl = config .ssl )
313
+ new_auth = Auth (new_user , ssh_con , ssl = config .ssl , haproxy = config . haproxy )
314
314
new_conn = new_auth .do_auth ()
315
315
new_name = new_user ["user_id" ]
316
316
out = reusable .unlink_bucket (user_info ["user_id" ], bucket_name )
@@ -545,7 +545,9 @@ def test_exec(config, ssh_con):
545
545
log .info (f"Bucket list output from secondary: { bucket_list_sec } " )
546
546
547
547
# List objects from sec site using boto3 rgw client
548
- other_site_auth = Auth (user_info , sec_site_ssh_con , ssl = config .ssl )
548
+ other_site_auth = Auth (
549
+ user_info , sec_site_ssh_con , ssl = config .ssl , haproxy = config .haproxy
550
+ )
549
551
sec_site_rgw_conn = other_site_auth .do_auth_using_client ()
550
552
resp = sec_site_rgw_conn .list_objects (Bucket = bucket .name )
551
553
log .info (f"List objects output using rgw client from sec site: { resp } " )
0 commit comments