@@ -77,7 +77,7 @@ def create_cluster(
77
77
return response
78
78
79
79
# TODO: Wrap create_cluster_snapshot
80
- def cluster_status (self , cluster_identifier : str ) -> str :
80
+ def cluster_status (self , cluster_identifier : str ) -> Any | None :
81
81
"""
82
82
Get status of a cluster.
83
83
@@ -92,7 +92,7 @@ def cluster_status(self, cluster_identifier: str) -> str:
92
92
except self .conn .exceptions .ClusterNotFoundFault :
93
93
return "cluster_not_found"
94
94
95
- async def cluster_status_async (self , cluster_identifier : str ) -> str :
95
+ async def cluster_status_async (self , cluster_identifier : str ) -> Any | None :
96
96
async with await self .get_async_conn () as client :
97
97
response = await client .describe_clusters (ClusterIdentifier = cluster_identifier )
98
98
return response ["Clusters" ][0 ]["ClusterStatus" ] if response else None
@@ -139,7 +139,7 @@ def describe_cluster_snapshots(self, cluster_identifier: str) -> list[str] | Non
139
139
snapshots .sort (key = lambda x : x ["SnapshotCreateTime" ], reverse = True )
140
140
return snapshots
141
141
142
- def restore_from_cluster_snapshot (self , cluster_identifier : str , snapshot_identifier : str ) -> str :
142
+ def restore_from_cluster_snapshot (self , cluster_identifier : str , snapshot_identifier : str ) -> Any | None :
143
143
"""
144
144
Restore a cluster from its snapshot.
145
145
@@ -160,7 +160,7 @@ def create_cluster_snapshot(
160
160
cluster_identifier : str ,
161
161
retention_period : int = - 1 ,
162
162
tags : list [Any ] | None = None ,
163
- ) -> str :
163
+ ) -> Any | None :
164
164
"""
165
165
Create a snapshot of a cluster.
166
166
0 commit comments