Update airflow/include/tasks/extract/utils/weaviate/ask_astro_weaviat…

…e_hook.py Co-authored-by: mpgreg <michaelgregory122@gmail.com>
astronomer · Nov 23, 2023 · f9f1b2a · f9f1b2a
1 parent 1bfd4ca
commit f9f1b2a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/include/tasks/extract/utils/weaviate/ask_astro_weaviate_hook.py b/airflow/include/tasks/extract/utils/weaviate/ask_astro_weaviate_hook.py
@@ -64,7 +64,7 @@ def is_class_missing(self, class_object: dict) -> bool:
         """
         try:
             class_schema = self.client.schema.get(class_object.get("class", ""))
-            return self.compare_schema_subset(class_object=class_object, class_schema=class_schema)
+            return not self.compare_schema_subset(class_object=class_object, class_schema=class_schema)
         except UnexpectedStatusCodeException as e:
             return e.status_code == 404 and "with response body: None." in e.message
         except Exception as e: