@@ -57,17 +57,18 @@ def create_bucket(self, bucket=None, bucket_name=None, org_id=None, retention_ru
57
57
58
58
try :
59
59
return self ._buckets_service .post_buckets (post_bucket_request = bucket )
60
- except ApiException as ex :
60
+ except ApiException :
61
61
# Fall back to v1 API if buckets are not supported
62
62
database_name = bucket_name if bucket_name is not None else bucket
63
63
return self .create_database (database = database_name , retention_rules = retention_rules )
64
64
65
65
def create_database (self , database = None , retention_rules = None ):
66
66
"""Create a database at the v1 api (legacy).
67
-
67
+
68
68
:param database_name: name of the new database
69
69
:param retention_rules: retention rules array or single BucketRetentionRules
70
- :return: Tuple (response body, status code, header dict)"""
70
+ :return: Tuple (response body, status code, header dict)
71
+ """
71
72
if database is None :
72
73
raise ValueError ("Invalid value for `database`, must be defined." )
73
74
@@ -122,15 +123,16 @@ def delete_bucket(self, bucket):
122
123
123
124
try :
124
125
return self ._buckets_service .delete_buckets_id (bucket_id = bucket_id )
125
- except ApiException as ex :
126
+ except ApiException :
126
127
return self .delete_database (database = bucket_id )
127
128
128
129
def delete_database (self , database = None ):
129
130
"""Delete a database at the v1 api (legacy).
130
-
131
+
131
132
:param database_name: name of the database to delete
132
133
:param retention_rules: retention rules array or single BucketRetentionRules
133
- :return: Tuple (response body, status code, header dict)"""
134
+ :return: Tuple (response body, status code, header dict)
135
+ """
134
136
if database is None :
135
137
raise ValueError ("Invalid value for `database`, must be defined." )
136
138
0 commit comments