Update cli/cli.py

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Author: jirhiker

cli/cli.py

@@ -945,18 +945,31 @@ def refresh_pygeoapi_materialized_views(
 ):
     from sqlalchemy import text
 
-    from db.engine import session_ctx
+    from db.engine import engine, session_ctx
 
     target_views = tuple(view) if view else PYGEOAPI_MATERIALIZED_VIEWS
-    refresh_clause = "CONCURRENTLY " if concurrently else ""
 
-    with session_ctx() as session:
-        for view_name in target_views:
-            safe_view = _validate_sql_identifier(view_name)
-            session.execute(
-                text(f"REFRESH MATERIALIZED VIEW {refresh_clause}{safe_view}")
-            )
-        session.commit()
+    if concurrently:
+        # PostgreSQL requires REFRESH MATERIALIZED VIEW CONCURRENTLY to run
+        # outside of a transaction block, so we use an AUTOCOMMIT connection
+        # instead of a Session (which would wrap the call in a transaction).
+        with engine.connect().execution_options(
+            isolation_level="AUTOCOMMIT"
+        ) as conn:
+            for view_name in target_views:
+                safe_view = _validate_sql_identifier(view_name)
+                conn.execute(
+                    text(f"REFRESH MATERIALIZED VIEW CONCURRENTLY {safe_view}")
+                )
+    else:
+        # Non-concurrent refresh can safely run inside a transaction.
+        with session_ctx() as session:
+            for view_name in target_views:
+                safe_view = _validate_sql_identifier(view_name)
+                session.execute(
+                    text(f"REFRESH MATERIALIZED VIEW {safe_view}")
+                )
+            session.commit()
 
     typer.echo(f"Refreshed {len(target_views)} materialized view(s).")