Fix call to textwrap.dedent

transferwise · Apr 19, 2022 · 0d6fb63 · 0d6fb63
1 parent f40d130
commit 0d6fb63
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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'