From 0a1b449564da883f55a8cec1b5199779d90c7782 Mon Sep 17 00:00:00 2001 From: Pathway-Dev <72749368+Pathway-Dev@users.noreply.github.com> Date: Fri, 31 Jan 2025 06:46:48 +0100 Subject: [PATCH] Daily Pathway examples refresh Co-authored-by: Manul from Pathway GitOrigin-RevId: 109845d676a41d8cfb967ff1a343470c1b3cde70 --- .../showcases/langchain-integration.ipynb | 2 +- .../tutorials/asynctransformer.ipynb | 110 +++++++++--------- .../notebooks/tutorials/consistency.ipynb | 2 +- examples/notebooks/tutorials/udf.ipynb | 8 +- 4 files changed, 58 insertions(+), 64 deletions(-) diff --git a/examples/notebooks/showcases/langchain-integration.ipynb b/examples/notebooks/showcases/langchain-integration.ipynb index 4cccb3e1..bd0ac35d 100644 --- a/examples/notebooks/showcases/langchain-integration.ipynb +++ b/examples/notebooks/showcases/langchain-integration.ipynb @@ -197,7 +197,7 @@ "id": "15", "metadata": {}, "source": [ - "The server is now running and ready for querying with a [`VectorStoreServer`](/developers/api-docs/pathway-xpacks-llm/vectorstore#pathway.xpacks.llm.vector_store.VectorStoreClient) ot with a `PathwayVectorClient` from `langchain-community` described in the next Section." + "The server is now running and ready for querying with a [`VectorStoreServer`](/developers/api-docs/pathway-xpacks-llm/vectorstore#pathway.xpacks.llm.vector_store.VectorStoreClient) or with a `PathwayVectorClient` from `langchain-community` described in the next Section." ] }, { diff --git a/examples/notebooks/tutorials/asynctransformer.ipynb b/examples/notebooks/tutorials/asynctransformer.ipynb index cc20c958..1181cc21 100644 --- a/examples/notebooks/tutorials/asynctransformer.ipynb +++ b/examples/notebooks/tutorials/asynctransformer.ipynb @@ -162,11 +162,11 @@ "output_type": "stream", "text": [ " | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 3 | 1738215341416 | 1\n", - "^3CZ78B4... | 2 | 3 | 1738215341618 | 1\n", - "^YYY4HAB... | 6 | 7 | 1738215341618 | 1\n", - "^3HN31E1... | 6 | 7 | 1738215342016 | 1\n", - "^X1MXHYY... | 12 | 13 | 1738215342018 | 1\n" + "^Z3QWT29... | 2 | 3 | 1738301911582 | 1\n", + "^3CZ78B4... | 2 | 3 | 1738301911784 | 1\n", + "^YYY4HAB... | 6 | 7 | 1738301911784 | 1\n", + "^3HN31E1... | 6 | 7 | 1738301912184 | 1\n", + "^X1MXHYY... | 12 | 13 | 1738301912184 | 1\n" ] } ], @@ -410,12 +410,12 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215351332 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215351432 | -1\n", - "^Z3QWT29... | 2 | 3 | 4 | 1738215351432 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215351632 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215351832 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738215351832 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1738301921414 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738301921514 | -1\n", + "^Z3QWT29... | 2 | 3 | 4 | 1738301921514 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301921714 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301921914 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738301921914 | 1\n" ] } ], @@ -537,18 +537,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215353752 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738215353752 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215354054 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738215354054 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1738215354054 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1738215354054 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215354154 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738215354154 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215354254 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738215354254 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738215354254 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1738215354254 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1738301923834 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738301923834 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738301924136 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738301924136 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1738301924136 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1738301924136 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301924236 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738301924236 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301924336 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738301924336 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738301924336 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1738301924336 | 1\n" ] } ], @@ -581,16 +581,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215355218 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1738215355318 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738215355420 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215355520 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738215355520 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1738215355520 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1738215355520 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215355620 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215355720 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738215355720 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1738301925300 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1738301925400 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738301925500 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738301925600 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738301925600 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1738301925600 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1738301925600 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301925700 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301925800 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738301925800 | 1\n" ] } ], @@ -633,18 +633,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215356686 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215356686 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738215356686 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738215356686 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215357188 | -1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215357188 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738215357188 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738215357188 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738215357188 | 1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1738215357188 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1738215357188 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1738215357188 | 1\n" + "^YYY4HAB... | 1 | 5 | 6 | 1738301926740 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738301926740 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738301926740 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738301926740 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301927240 | -1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738301927240 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738301927240 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738301927240 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738301927240 | 1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1738301927240 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1738301927240 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1738301927240 | 1\n" ] } ], @@ -688,16 +688,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215358160 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738215358160 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738215358460 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738215358460 | -1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215358560 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738215358560 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738215358660 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738215358660 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738215358660 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1738215358660 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1738301928204 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738301928204 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738301928506 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738301928506 | -1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301928606 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738301928606 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738301928704 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738301928704 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738301928704 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1738301928704 | 1\n" ] } ], diff --git a/examples/notebooks/tutorials/consistency.ipynb b/examples/notebooks/tutorials/consistency.ipynb index 73c8d144..9b74affc 100644 --- a/examples/notebooks/tutorials/consistency.ipynb +++ b/examples/notebooks/tutorials/consistency.ipynb @@ -327,7 +327,7 @@ "name": "stderr", "output_type": "stream", "text": [ - "INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 0 entries, time 1738215575796. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n" + "INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 0 entries, time 1738302145770. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n" ] }, { diff --git a/examples/notebooks/tutorials/udf.ipynb b/examples/notebooks/tutorials/udf.ipynb index 3809f384..c7f03a43 100644 --- a/examples/notebooks/tutorials/udf.ipynb +++ b/examples/notebooks/tutorials/udf.ipynb @@ -893,13 +893,7 @@ "inc_async(0.6) starting\n", "inc_async(2.0) starting\n", "inc_async(0.2) starting\n", - "inc_async(1.2) starting\n" - ] - }, - { - "name": "stdout", - "output_type": "stream", - "text": [ + "inc_async(1.2) starting\n", "inc_async(0.2) finishing\n" ] },