wip

posthog/client.py

@@ -270,7 +270,7 @@ class Client(object):
         self.project_root = project_root
 
         self.use_ai_ingestion_pipeline = os.environ.get(
-            "LLMA_INGESTION_PIPELINE", "false"
+            "_INTERNAL_LLMA_INGESTION_PIPELINE", "false"
         ).lower() in ("true", "1", "yes")
 
         # personal_api_key: This should be a generated Personal API Key, private

posthog/request.py

@@ -383,9 +383,10 @@ def build_ai_multipart_request(
 
     # Part 3+: blob parts
     for blob_name, blob_value in blobs.items():
+        blob_id = str(uuid4())
         parts.append(f"--{boundary}\r\n".encode())
         parts.append(
-            f'Content-Disposition: form-data; name="event.properties.{blob_name}"\r\n'.encode()
+            f'Content-Disposition: form-data; name="event.properties.{blob_name}"; filename="{blob_id}"\r\n'.encode()
         )
         parts.append(b"Content-Type: application/json\r\n\r\n")
         parts.append(json.dumps(blob_value, cls=DatetimeSerializer).encode("utf-8"))

posthog/utils.py

@@ -541,7 +541,7 @@ def extract_ai_blob_properties(
         >>> # blobs = {"$ai_input": [...], "$ai_output_choices": [...]}
     """
     # Properties to extract as blobs
-    blob_property_names = {"$ai_input", "$ai_output_choices"}
+    blob_property_names = {"$ai_input", "$ai_output_choices", "$ai_embedding_vector"}
 
     # Create a copy of properties without the blob properties
     cleaned_properties = {