diff --git a/roles/pg_migration/templates/copy-progress b/roles/pg_migration/templates/copy-progress index 171c44e0..d139616b 100644 --- a/roles/pg_migration/templates/copy-progress +++ b/roles/pg_migration/templates/copy-progress @@ -59,7 +59,7 @@ function relation_progress() { function overall_progress() { - tables=$(psql ${DSTPG} -AXtwc "SELECT relname FROM pg_class c JOIN pg_subscription_rel sr ON c.oid = sr.srrelid WHERE relkind = 'r' AND srsubstate != 'r';") + tables=$(psql ${DSTPG} -AXtwc "SELECT quote_ident(n.nspname) || '.' || quote_ident(c.relname) AS name FROM pg_class c JOIN pg_namespace n ON c.relnamespace = n.oid JOIN pg_subscription_rel sr ON c.oid = sr.srrelid WHERE c.relkind = 'r' AND sr.srsubstate != 'r';") for table in $tables; do relation_progress ${table} done