@@ -2860,8 +2860,11 @@ def correct_postgresql_password(
2860
2860
readwrite_conns = connections (spec , meta , patch ,
2861
2861
get_field (POSTGRESQL , READWRITEINSTANCE ),
2862
2862
False , None , logger , None , status , False )
2863
- conn = get_primary_conn (readwrite_conns , 0 , logger )
2864
- correct_user_password (meta , spec , patch , status , logger , conn )
2863
+ conn = get_primary_conn (readwrite_conns , 0 , logger , interrupt = False )
2864
+ if conn == None :
2865
+ logger .error (f"can't correct readwrite password. because get primary conn failed" )
2866
+ else :
2867
+ correct_user_password (meta , spec , patch , status , logger , conn )
2865
2868
readwrite_conns .free_conns ()
2866
2869
2867
2870
@@ -2967,8 +2970,8 @@ def timer_cluster(
2967
2970
) -> None :
2968
2971
2969
2972
correct_postgresql_role (meta , spec , patch , status , logger )
2970
- correct_postgresql_password (meta , spec , patch , status , logger )
2971
2973
correct_keepalived (meta , spec , patch , status , logger )
2974
+ correct_postgresql_password (meta , spec , patch , status , logger )
2972
2975
2973
2976
def update_number_sync_standbys (
2974
2977
meta : kopf .Meta ,
@@ -3530,7 +3533,7 @@ def update_configs_utile(
3530
3533
# pg_autoctl set node candidate-priority 0 --pgdata=s
3531
3534
3532
3535
if autofailover == False and restart == True :
3533
- update_node_priority (meta , spec , patch , status , logger , conns , NODE_PRIORITY_NEVER , primary_host )
3536
+ update_node_priority (meta , spec , patch , status , logger , readwrite_conns . get_conns () , NODE_PRIORITY_NEVER , primary_host )
3534
3537
3535
3538
# first update primary node
3536
3539
checkpoint_cmd = ["pgtools" , "-w" , "0" , "-q" , "'checkpoint'" ]
@@ -3583,7 +3586,7 @@ def update_configs_utile(
3583
3586
waiting_postgresql_ready (readonly_conns , logger )
3584
3587
waiting_cluster_final_status (meta , spec , patch , status , logger )
3585
3588
if autofailover == False and restart == True :
3586
- update_node_priority (meta , spec , patch , status , logger , conns , NODE_PRIORITY_DEFAULT , primary_host )
3589
+ update_node_priority (meta , spec , patch , status , logger , readwrite_conns . get_conns () , NODE_PRIORITY_DEFAULT , primary_host )
3587
3590
waiting_cluster_final_status (meta , spec , patch , status , logger )
3588
3591
3589
3592
def update_configs_port (
0 commit comments