diff --git a/psrdb/graphql_client.py b/psrdb/graphql_client.py
index 51e71a8..c1b69a4 100644
--- a/psrdb/graphql_client.py
+++ b/psrdb/graphql_client.py
@@ -47,6 +47,7 @@ def handle_error_msg(self, content):
             if "message" in content["errors"][0]:
                 message = content["errors"][0]["message"]
             self.logger.error(f"Error: {message}")
+            raise Exception(f"Error: {message}")
 
     def post(self, payload):
         """Post the payload and header to the GraphQL URL."""
diff --git a/psrdb/graphql_table.py b/psrdb/graphql_table.py
index 2a2f9f1..a4f1ea5 100644
--- a/psrdb/graphql_table.py
+++ b/psrdb/graphql_table.py
@@ -118,9 +118,11 @@ def parse_mutation_response(self, response, table_name, mutation_name):
                     else:
                         print(created_data["id"])
             else:
-                self.logger.warning(f"Errors returned in content {content['errors']}")
+                self.logger.error(f"Errors returned in content {content['errors']}")
+                raise Exception(f"Errors returned in content {content['errors']}")
         else:
-            self.logger.warning(f"Bad response status_code={response.status_code}")
+            self.logger.error(f"Bad response status_code={response.status_code}")
+            raise Exception(f"Bad response status_code={response.status_code}")
         return None
 
     def mutation_graphql(self):
@@ -194,7 +196,12 @@ def list_graphql(
                             result.append(node["node"])
                         self.print_record_set(node["node"], "\t", print_headers=print_headers)
                         print_headers = cursor is None
-
+                else:
+                    self.logger.error(f"Errors returned in content {content['errors']}")
+                    raise Exception(f"Errors returned in content {content['errors']}")
+            else:
+                self.logger.error(f"Bad response status_code={response.status_code}")
+                raise Exception(f"Bad response status_code={response.status_code}")
         if self.get_dicts:
             return result
         else: