Merge branch 'main' into update-watch

Author: georgeh0

examples/amazon_s3_embedding/main.py

@@ -101,7 +101,16 @@ def _main() -> None:
     pool = ConnectionPool(os.getenv("COCOINDEX_DATABASE_URL"))
 
     amazon_s3_text_embedding_flow.setup()
-    with cocoindex.FlowLiveUpdater(amazon_s3_text_embedding_flow):
+    with cocoindex.FlowLiveUpdater(amazon_s3_text_embedding_flow) as updater:
+        updater.abort()
+        updater.wait()
+
+        while True:
+            updates = updater.next_status_updates()
+            print(f"Updates: {updates}")
+            if not updates.active_sources:
+                break
+
         # Run queries in a loop to demonstrate the query capabilities.
         while True:
             query = input("Enter search query (or Enter to quit): ")