|
115 | 115 | |
116 | 116 | credential = w.storage_credentials.create( |
117 | 117 | name=f"sdk-{time.time_ns()}", |
118 | | - aws_iam_role=catalog.AwsIamRole(role_arn=os.environ["TEST_METASTORE_DATA_ACCESS_ARN"]), |
| 118 | + aws_iam_role=catalog.AwsIamRoleRequest(role_arn=os.environ["TEST_METASTORE_DATA_ACCESS_ARN"]), |
119 | 119 | ) |
120 | 120 | |
121 | 121 | created = w.external_locations.create( |
122 | 122 | name=f"sdk-{time.time_ns()}", |
123 | 123 | credential_name=credential.name, |
124 | | - url=f's3://{os.environ["TEST_BUCKET"]}/sdk-{time.time_ns()}', |
| 124 | + url="s3://%s/%s" % (os.environ["TEST_BUCKET"], f"sdk-{time.time_ns()}"), |
125 | 125 | ) |
126 | 126 | |
127 | | - _ = w.external_locations.get(get=created.name) |
| 127 | + _ = w.external_locations.get(name=created.name) |
128 | 128 | |
129 | 129 | # cleanup |
130 | | - w.storage_credentials.delete(delete=credential.name) |
131 | | - w.external_locations.delete(delete=created.name) |
| 130 | + w.storage_credentials.delete(name=credential.name) |
| 131 | + w.external_locations.delete(name=created.name) |
132 | 132 |
|
133 | 133 | Gets an external location from the metastore. The caller must be either a metastore admin, the owner |
134 | 134 | of the external location, or a user that has some privilege on the external location. |
|
200 | 200 | |
201 | 201 | credential = w.storage_credentials.create( |
202 | 202 | name=f"sdk-{time.time_ns()}", |
203 | | - aws_iam_role=catalog.AwsIamRole(role_arn=os.environ["TEST_METASTORE_DATA_ACCESS_ARN"]), |
| 203 | + aws_iam_role=catalog.AwsIamRoleRequest(role_arn=os.environ["TEST_METASTORE_DATA_ACCESS_ARN"]), |
204 | 204 | ) |
205 | 205 | |
206 | 206 | created = w.external_locations.create( |
207 | 207 | name=f"sdk-{time.time_ns()}", |
208 | 208 | credential_name=credential.name, |
209 | | - url=f's3://{os.environ["TEST_BUCKET"]}/sdk-{time.time_ns()}', |
| 209 | + url="s3://%s/%s" % (os.environ["TEST_BUCKET"], f"sdk-{time.time_ns()}"), |
210 | 210 | ) |
211 | 211 | |
212 | 212 | _ = w.external_locations.update( |
213 | 213 | name=created.name, |
214 | 214 | credential_name=credential.name, |
215 | | - url=f's3://{os.environ["TEST_BUCKET"]}/sdk-{time.time_ns()}', |
| 215 | + url="s3://%s/%s" % (os.environ["TEST_BUCKET"], f"sdk-{time.time_ns()}"), |
216 | 216 | ) |
217 | 217 | |
218 | 218 | # cleanup |
219 | | - w.storage_credentials.delete(delete=credential.name) |
220 | | - w.external_locations.delete(delete=created.name) |
| 219 | + w.storage_credentials.delete(name=credential.name) |
| 220 | + w.external_locations.delete(name=created.name) |
221 | 221 |
|
222 | 222 | Updates an external location in the metastore. The caller must be the owner of the external location, |
223 | 223 | or be a metastore admin. In the second case, the admin can only update the name of the external |
|
0 commit comments