diff --git a/aiven_db_migrate/migrate/pgmigrate.py b/aiven_db_migrate/migrate/pgmigrate.py
index c85aa9f..1f19dc8 100644
--- a/aiven_db_migrate/migrate/pgmigrate.py
+++ b/aiven_db_migrate/migrate/pgmigrate.py
@@ -1241,7 +1241,7 @@ def _decode_output_line(line: bytes):
 
     def _pg_dump_pipe_psql(self, *, pg_dump_cmd: Sequence[str], target_conn_str: str) -> PGSubTask:
         psql_cmd = [
-            "psql",
+            str(self.pgbin / "psql"),
             "--no-psqlrc",
             "--echo-all" if self.verbose else "--echo-errors",
             # "--variable=ON_ERROR_STOP=1",