Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

MDB-33721: extracted wal_reciever info, fix finish_iteration position and cascade replication #59

Open
wants to merge 12 commits into
base: main
Choose a base branch
from

Conversation

aak74
Copy link
Contributor

@aak74 aak74 commented Feb 5, 2025

Repairing pgconsul crash and fix delay when exception occurs

@aak74 aak74 requested a review from a team as a code owner February 5, 2025 11:27
fedusia
fedusia previously approved these changes Feb 5, 2025
fedusia
fedusia previously approved these changes Feb 6, 2025
Andrey Kopylov added 3 commits February 24, 2025 15:35
@aak74 aak74 changed the title MDB-33721: extracted wal_reciever info, fix finish_iteration position MDB-33721: extracted wal_reciever info, fix finish_iteration position and cascade replication Mar 4, 2025
@aak74 aak74 requested a review from vicpopov March 7, 2025 13:00
@@ -88,7 +91,7 @@ def update_replication_type(self, db_state, ha_replics):
# https://www.postgresql.org/message-id/15617-8dfbde784d8e3258%40postgresql.org
self._db.check_walsender(db_state['replics_info'], holder_fqdn)
else:
logging.info("Here we should turn synchronous replication on.")
logging.info("ACTION. Here we should turn synchronous replication on.")
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ACTION. Turning synchronous replication ON.

@@ -1050,7 +1034,7 @@ def _simple_primary_switch(self, limit, new_primary, is_dead):
primary_switch_checks = self.config.getint('replica', 'primary_switch_checks')
need_restart = self.config.getboolean('replica', 'primary_switch_restart')

logging.info('Starting simple primary switch.')
logging.info('ACTION. Starting simple primary switch to {}'.format(new_primary))
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Here we are just beginning a sequence of steps to perform switch, it is not a simple action that should be logged as intent with ACTION.

@@ -1084,7 +1068,8 @@ def _simple_primary_switch(self, limit, new_primary, is_dead):
#
# The easy way succeeded.
#
logging.info('Simple primary switch succeeded.')
logging.info('ACTION. Simple switch primary to {} succeeded'.format(new_primary))
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Same as on R1037, it is not an ACTION, but a branch of execution that ended here.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants