|
54 | 54 |
|
55 | 55 | PG_BASE_CONF_PATH = f"{POSTGRESQL_CONF_PATH}/postgresql.conf"
|
56 | 56 |
|
57 |
| -RUNNING_STATES = ["running", "streaming"] |
| 57 | +STARTED_STATES = ["running", "streaming"] |
| 58 | +RUNNING_STATES = [*STARTED_STATES, "starting"] |
58 | 59 |
|
59 | 60 | PATRONI_TIMEOUT = 10
|
60 | 61 |
|
@@ -345,7 +346,7 @@ def get_standby_leader(
|
345 | 346 | if cluster_status:
|
346 | 347 | for member in cluster_status:
|
347 | 348 | if member["role"] == "standby_leader":
|
348 |
| - if check_whether_is_running and member["state"] not in RUNNING_STATES: |
| 349 | + if check_whether_is_running and member["state"] not in STARTED_STATES: |
349 | 350 | logger.warning(f"standby leader {member['name']} is not running")
|
350 | 351 | continue
|
351 | 352 | standby_leader = member["name"]
|
@@ -415,7 +416,7 @@ def are_all_members_ready(self) -> bool:
|
415 | 416 | # a standby leader, because sometimes there may exist (for some period of time)
|
416 | 417 | # only replicas after a failed switchover.
|
417 | 418 | return all(
|
418 |
| - member["state"] in RUNNING_STATES for member in cluster_status.json()["members"] |
| 419 | + member["state"] in STARTED_STATES for member in cluster_status.json()["members"] |
419 | 420 | ) and any(
|
420 | 421 | member["role"] in ["leader", "standby_leader"]
|
421 | 422 | for member in cluster_status.json()["members"]
|
@@ -573,7 +574,7 @@ def online_cluster_members(self) -> list[ClusterMember]:
|
573 | 574 | if not cluster_status:
|
574 | 575 | return []
|
575 | 576 |
|
576 |
| - return [member for member in cluster_status if member["state"] in RUNNING_STATES] |
| 577 | + return [member for member in cluster_status if member["state"] in STARTED_STATES] |
577 | 578 |
|
578 | 579 | def are_replicas_up(self) -> dict[str, bool] | None:
|
579 | 580 | """Check if cluster members are running or streaming."""
|
|
0 commit comments