Skip to content

Commit ad59c85

Browse files
committed
Pass through index aliases when checking if index closed
Signed-off-by: Étienne Beaulé <[email protected]>
1 parent cab21f1 commit ad59c85

File tree

2 files changed

+12
-2
lines changed

2 files changed

+12
-2
lines changed

opensearchpy/_async/helpers/index.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,12 @@ async def is_closed(self, using: Any = None) -> Any:
288288
state = await (await self._get_connection(using)).cluster.state(
289289
index=self._name, metric="metadata"
290290
)
291-
return state["metadata"]["indices"][self._name]["state"] == "close"
291+
index_name = (
292+
next(iter(state["metadata"]["indices"].keys()))
293+
if len(state["metadata"]["indices"].keys()) == 1
294+
else self._name
295+
)
296+
return state["metadata"]["indices"][index_name]["state"] == "close"
292297

293298
async def save(self, using: Any = None) -> Any:
294299
"""

opensearchpy/helpers/index.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -309,7 +309,12 @@ def is_closed(self, using: Optional[OpenSearch] = None) -> Any:
309309
state = self._get_connection(using).cluster.state(
310310
index=self._name, metric="metadata"
311311
)
312-
return state["metadata"]["indices"][self._name]["state"] == "close"
312+
index_name = (
313+
next(iter(state["metadata"]["indices"].keys()))
314+
if len(state["metadata"]["indices"].keys()) == 1
315+
else self._name
316+
)
317+
return state["metadata"]["indices"][index_name]["state"] == "close"
313318

314319
def save(self, using: Optional[OpenSearch] = None) -> Any:
315320
"""

0 commit comments

Comments
 (0)