diff --git a/docs/examples/postgres_to_postgres/postgres_to_postgres.py b/docs/examples/postgres_to_postgres/postgres_to_postgres.py
index 870d619562..63b33c5795 100644
--- a/docs/examples/postgres_to_postgres/postgres_to_postgres.py
+++ b/docs/examples/postgres_to_postgres/postgres_to_postgres.py
@@ -216,7 +216,7 @@ def table_desc(table_name, pk, schema_name, order_date, columns="*"):
     if load_type == "replace":
         # 4. Load DuckDB local database into Postgres
         print("##################################### START DUCKDB LOAD ########")
-        conn = duckdb.connect(f"{pipeline_name}.duckdb")
+        conn = duckdb.connect(f"{load_info.destination_displayable_credentials}".split(":///")[1])
         conn.install_extension(
             "./postgres_scanner.duckdb_extension"
         )  # duckdb_extension is downloaded/installed manually here, only needed if `LOAD/INSTALL postgres` throws an error