@@ -386,7 +386,7 @@ def remove(udf_info: FunctionInfo):
386386
387387
388388@fixture
389- def make_storage_credential (ws ) -> Generator [Callable [..., StorageCredentialInfo ], None , None ]:
389+ def make_storage_credential (ws , watchdog_remove_after ) -> Generator [Callable [..., StorageCredentialInfo ], None , None ]:
390390 """
391391 Create a storage credential and return its info. Remove it after the test. Returns instance of `databricks.sdk.service.catalog.StorageCredentialInfo`.
392392
@@ -419,14 +419,15 @@ def create(
419419 aws_iam_role_arn : str = "" ,
420420 read_only = False ,
421421 ) -> StorageCredentialInfo :
422+ comment = { "RemoveAfter" : watchdog_remove_after }
422423 if aws_iam_role_arn != "" :
423424 storage_credential = ws .storage_credentials .create (
424- credential_name , aws_iam_role = AwsIamRoleRequest (role_arn = aws_iam_role_arn ), read_only = read_only
425+ credential_name , aws_iam_role = AwsIamRoleRequest (role_arn = aws_iam_role_arn ), read_only = read_only , comment = comment
425426 )
426427 else :
427428 azure_service_principal = AzureServicePrincipal (directory_id , application_id , client_secret )
428429 storage_credential = ws .storage_credentials .create (
429- credential_name , azure_service_principal = azure_service_principal , read_only = read_only
430+ credential_name , azure_service_principal = azure_service_principal , read_only = read_only , comment = comment
430431 )
431432 return storage_credential
432433
0 commit comments