Move universe check to index internals (#4818)

* Move universe check to index internals * bump pathway GitOrigin-RevId: 21a6aa56233cb72f7c3a992f893f1f6651a3df14
AbhiZx18324 · Oct 19, 2023 · 42e915d · 42e915d
1 parent 59aafd5
commit 42e915d
Show file tree

Hide file tree

Showing 6 changed files with 903 additions and 883 deletions.
diff --git a/examples/pipelines/contextful/app.py b/examples/pipelines/contextful/app.py
@@ -85,7 +85,7 @@ def run(
 
     query_context = query + index.get_nearest_items(
         query.vector, k=3, collapse_rows=True
-    ).select(documents_list=pw.this.doc).promise_universe_is_equal_to(query)
+    ).select(documents_list=pw.this.doc)
 
     @pw.udf
     def build_prompt(documents, query):

diff --git a/examples/pipelines/contextful_s3/app.py b/examples/pipelines/contextful_s3/app.py
@@ -88,7 +88,7 @@ def run(
 
     query_context = query + index.get_nearest_items(
         query.vector, k=3, collapse_rows=True
-    ).select(documents_list=pw.this.doc).promise_universe_is_equal_to(query)
+    ).select(documents_list=pw.this.doc)
 
     @pw.udf
     def build_prompt(documents, query):

diff --git a/examples/pipelines/local/app.py b/examples/pipelines/local/app.py
@@ -85,7 +85,7 @@ def run(
 
     query_context = query + index.get_nearest_items(
         query.vector, k=3, collapse_rows=True
-    ).select(documents_list=pw.this.doc).promise_universe_is_equal_to(query)
+    ).select(documents_list=pw.this.doc)
 
     @pw.udf
     def build_prompt(documents, query):

diff --git a/examples/pipelines/unstructured/app.py b/examples/pipelines/unstructured/app.py
@@ -89,7 +89,7 @@ def run(
 
     query_context = query + index.get_nearest_items(
         query.vector, k=3, collapse_rows=True
-    ).select(documents_list=pw.this.chunk).promise_universe_is_equal_to(query)
+    ).select(documents_list=pw.this.chunk)
 
     @pw.udf
     def build_prompt(documents, query):