Account for soft-deleted subjects (confluentinc#1127)

PatrickTu · May 25, 2021 · e3df0b9 · e3df0b9
1 parent e1c3227
commit e3df0b9
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/confluent_kafka/schema_registry/schema_registry_client.py b/src/confluent_kafka/schema_registry/schema_registry_client.py
@@ -458,12 +458,16 @@ def delete_subject(self, subject_name, permanent=False):
             `DELETE Subject API Reference <https://docs.confluent.io/current/schema-registry/develop/api.html#delete--subjects-(string-%20subject)>`_
 
         """  # noqa: E501
-        list = self._rest_client.delete('subjects/{}'
-                                        .format(_urlencode(subject_name)))
+        try:
+            list = self._rest_client.delete('subjects/{}'
+                                            .format(_urlencode(subject_name)))
+        except SchemaRegistryError as e:
+            if e.error_code != 40404:
+                raise
 
         if permanent:
-            self._rest_client.delete('subjects/{}?permanent=true'
-                                     .format(_urlencode(subject_name)))
+            list = self._rest_client.delete('subjects/{}?permanent=true'
+                                            .format(_urlencode(subject_name)))
 
         return list