Fix: DROP REPOSITORY now returns RepositoryMissingException

CHANGES.md

@@ -16,6 +16,10 @@
 
 - Use full-qualified table names everywhere.
 
+- Fix: Compensate for `DROP REPOSITORY` now returning `RepositoryMissingException`
+  when the repository does not exist. With previous versions of CrateDB, it was
+  `RepositoryUnknownException`.
+
 ## 2023/06/27 0.0.0
 
 - Import "data retention" implementation from <https://github.com/crate/crate-airflow-tutorial>.

cratedb_retention/util/data.py

@@ -7,3 +7,11 @@ def jd(data: t.Any):
     Pretty-print JSON with indentation.
     """
     print(json.dumps(data, indent=2))  # noqa: T201
+
+
+def str_contains(haystack, *needles):
+    """
+    Whether haystack contains any of the provided needles.
+    """
+    haystack = str(haystack)
+    return any(needle in haystack for needle in needles)

cratedb_retention/util/database.py

@@ -4,6 +4,8 @@
 from sqlalchemy.exc import ProgrammingError
 from sqlalchemy.sql.elements import AsBoolean
 
+from cratedb_retention.util.data import str_contains
+
 
 def run_sql(dburi: str, sql: str, records: bool = False):
     return DatabaseAdapter(dburi=dburi).run_sql(sql=sql, records=records)
@@ -70,7 +72,7 @@ def drop_repository(self, name: str):
             sql = f"DROP REPOSITORY {name};"
             self.run_sql(sql)
         except ProgrammingError as ex:
-            if "RepositoryUnknownException" not in str(ex):
+            if not str_contains(ex, "RepositoryUnknownException", "RepositoryMissingException"):
                 raise
 
     def ensure_repository_fs(