wcs/sql.py

@@ -384,8 +384,10 @@ def guard_postgres(func):
         try:
             return func(*args, **kwargs)
         except psycopg2.Error:
-            get_publisher().capture_exception(sys.exc_info())
-            get_connection().rollback()
+            conn = get_connection()
+            if conn:
+                get_publisher().capture_exception(sys.exc_info())
+                conn.rollback()
             raise
 
     return f