diff --git a/app/services/postgresql_query_service.rb b/app/services/postgresql_query_service.rb
index cb33c528a2..0c8b02a70c 100644
--- a/app/services/postgresql_query_service.rb
+++ b/app/services/postgresql_query_service.rb
@@ -39,7 +39,7 @@ class PostgresqlQueryService
       result = connection.exec(query_text)
 
     rescue StandardError => e
-      reset_connection(data_source) if connection.finished?
+      reset_connection(data_source) if connection&.finished?
 
       puts e
       error = { message: e.message }