Update weaviate_utils.py

weaviate_utils.py

@@ -46,4 +46,16 @@ def ingest_data_to_weaviate(client, dataframe, class_name, class_description):
         }
         try:
             client.schema.property.create(class_name, property_schema)
-        except weaviate.exceptions.SchemaValidation:
+        except weaviate.exceptions.SchemaValidationException:
+            # Property might already exist, so we can continue
+            pass
+
+    # Now, let's ingest the data
+    data = dataframe.to_dict(orient="records")
+    client.data_object.create(data, class_name)
+
+def get_class_schema(client, class_name):
+    try:
+        return client.schema.get_class(class_name)
+    except weaviate.exceptions.SchemaValidationException:
+        return None