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'