|
107 | 107 | |
108 | 108 | credential = w.storage_credentials.create( |
109 | 109 | name=f"sdk-{time.time_ns()}", |
110 | | - aws_iam_role=catalog.AwsIamRoleRequest(role_arn=os.environ["TEST_METASTORE_DATA_ACCESS_ARN"]), |
| 110 | + aws_iam_role=catalog.AwsIamRole(role_arn=os.environ["TEST_METASTORE_DATA_ACCESS_ARN"]), |
111 | 111 | ) |
112 | 112 | |
113 | 113 | created = w.external_locations.create( |
114 | 114 | name=f"sdk-{time.time_ns()}", |
115 | 115 | credential_name=credential.name, |
116 | | - url="s3://%s/%s" % (os.environ["TEST_BUCKET"], f"sdk-{time.time_ns()}"), |
| 116 | + url=f's3://{os.environ["TEST_BUCKET"]}/sdk-{time.time_ns()}', |
117 | 117 | ) |
118 | 118 | |
119 | | - _ = w.external_locations.get(name=created.name) |
| 119 | + _ = w.external_locations.get(get=created.name) |
120 | 120 | |
121 | 121 | # cleanup |
122 | | - w.storage_credentials.delete(name=credential.name) |
123 | | - w.external_locations.delete(name=created.name) |
| 122 | + w.storage_credentials.delete(delete=credential.name) |
| 123 | + w.external_locations.delete(delete=created.name) |
124 | 124 |
|
125 | 125 | Gets an external location from the metastore. The caller must be either a metastore admin, the owner |
126 | 126 | of the external location, or a user that has some privilege on the external location. |
|
193 | 193 | |
194 | 194 | credential = w.storage_credentials.create( |
195 | 195 | name=f"sdk-{time.time_ns()}", |
196 | | - aws_iam_role=catalog.AwsIamRole(role_arn=os.environ["TEST_METASTORE_DATA_ACCESS_ARN"]), |
| 196 | + aws_iam_role=catalog.AwsIamRoleRequest(role_arn=os.environ["TEST_METASTORE_DATA_ACCESS_ARN"]), |
197 | 197 | ) |
198 | 198 | |
199 | 199 | created = w.external_locations.create( |
200 | 200 | name=f"sdk-{time.time_ns()}", |
201 | 201 | credential_name=credential.name, |
202 | | - url=f's3://{os.environ["TEST_BUCKET"]}/sdk-{time.time_ns()}', |
| 202 | + url="s3://%s/%s" % (os.environ["TEST_BUCKET"], f"sdk-{time.time_ns()}"), |
203 | 203 | ) |
204 | 204 | |
205 | 205 | _ = w.external_locations.update( |
206 | 206 | name=created.name, |
207 | 207 | credential_name=credential.name, |
208 | | - url=f's3://{os.environ["TEST_BUCKET"]}/sdk-{time.time_ns()}', |
| 208 | + url="s3://%s/%s" % (os.environ["TEST_BUCKET"], f"sdk-{time.time_ns()}"), |
209 | 209 | ) |
210 | 210 | |
211 | 211 | # cleanup |
212 | | - w.storage_credentials.delete(delete=credential.name) |
213 | | - w.external_locations.delete(delete=created.name) |
| 212 | + w.storage_credentials.delete(name=credential.name) |
| 213 | + w.external_locations.delete(name=created.name) |
214 | 214 |
|
215 | 215 | Updates an external location in the metastore. The caller must be the owner of the external location, |
216 | 216 | or be a metastore admin. In the second case, the admin can only update the name of the external |
|
0 commit comments