From 0d6fb6334a6118739bd91f01ff278b5918efc228 Mon Sep 17 00:00:00 2001 From: Judah Rand <17158624+judahrand@users.noreply.github.com> Date: Tue, 19 Apr 2022 09:19:44 +0100 Subject: [PATCH] Fix call to `textwrap.dedent` --- pipelinewise/fastsync/commons/tap_postgres.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pipelinewise/fastsync/commons/tap_postgres.py b/pipelinewise/fastsync/commons/tap_postgres.py index 6559a0515..70346c1b4 100644 --- a/pipelinewise/fastsync/commons/tap_postgres.py +++ b/pipelinewise/fastsync/commons/tap_postgres.py @@ -295,7 +295,8 @@ def get_confirmed_flush_lsn(self) -> int: res = self.primary_host_query( textwrap.dedent( - f"""SELECT * + f"""\ + SELECT * FROM pg_replication_slots WHERE slot_name = '{slot_name}' AND plugin = 'wal2json'