Skip to content

Commit 0a1b449

Browse files
Pathway-DevManul from Pathway
Pathway-Dev
and
Manul from Pathway
committed
Daily Pathway examples refresh
Co-authored-by: Manul from Pathway <github.manul@pathway.com> GitOrigin-RevId: 109845d676a41d8cfb967ff1a343470c1b3cde70
1 parent bd9a1cd commit 0a1b449

File tree

4 files changed

+58
-64
lines changed

4 files changed

+58
-64
lines changed

‎examples/notebooks/showcases/langchain-integration.ipynb‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -197,7 +197,7 @@
197197
"id": "15",
198198
"metadata": {},
199199
"source": [
200-
"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."
200+
"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."
201201
]
202202
},
203203
{

‎examples/notebooks/tutorials/asynctransformer.ipynb‎

Lines changed: 55 additions & 55 deletions
Original file line numberDiff line numberDiff line change
@@ -162,11 +162,11 @@
162162
"output_type": "stream",
163163
"text": [
164164
" | value | ret | __time__ | __diff__\n",
165-
"^Z3QWT29... | 2 | 3 | 1738215341416 | 1\n",
166-
"^3CZ78B4... | 2 | 3 | 1738215341618 | 1\n",
167-
"^YYY4HAB... | 6 | 7 | 1738215341618 | 1\n",
168-
"^3HN31E1... | 6 | 7 | 1738215342016 | 1\n",
169-
"^X1MXHYY... | 12 | 13 | 1738215342018 | 1\n"
165+
"^Z3QWT29... | 2 | 3 | 1738301911582 | 1\n",
166+
"^3CZ78B4... | 2 | 3 | 1738301911784 | 1\n",
167+
"^YYY4HAB... | 6 | 7 | 1738301911784 | 1\n",
168+
"^3HN31E1... | 6 | 7 | 1738301912184 | 1\n",
169+
"^X1MXHYY... | 12 | 13 | 1738301912184 | 1\n"
170170
]
171171
}
172172
],
@@ -410,12 +410,12 @@
410410
"output_type": "stream",
411411
"text": [
412412
" | group | value | ret | __time__ | __diff__\n",
413-
"^Z3QWT29... | 2 | 1 | 2 | 1738215351332 | 1\n",
414-
"^Z3QWT29... | 2 | 1 | 2 | 1738215351432 | -1\n",
415-
"^Z3QWT29... | 2 | 3 | 4 | 1738215351432 | 1\n",
416-
"^YYY4HAB... | 1 | 5 | 6 | 1738215351632 | 1\n",
417-
"^YYY4HAB... | 1 | 5 | 6 | 1738215351832 | -1\n",
418-
"^YYY4HAB... | 1 | 2 | 3 | 1738215351832 | 1\n"
413+
"^Z3QWT29... | 2 | 1 | 2 | 1738301921414 | 1\n",
414+
"^Z3QWT29... | 2 | 1 | 2 | 1738301921514 | -1\n",
415+
"^Z3QWT29... | 2 | 3 | 4 | 1738301921514 | 1\n",
416+
"^YYY4HAB... | 1 | 5 | 6 | 1738301921714 | 1\n",
417+
"^YYY4HAB... | 1 | 5 | 6 | 1738301921914 | -1\n",
418+
"^YYY4HAB... | 1 | 2 | 3 | 1738301921914 | 1\n"
419419
]
420420
}
421421
],
@@ -537,18 +537,18 @@
537537
"output_type": "stream",
538538
"text": [
539539
" | group | value | ret | __time__ | __diff__\n",
540-
"^Z3QWT29... | 2 | 1 | 2 | 1738215353752 | 1\n",
541-
"^3HN31E1... | 4 | 3 | 4 | 1738215353752 | 1\n",
542-
"^Z3QWT29... | 2 | 1 | 2 | 1738215354054 | -1\n",
543-
"^3HN31E1... | 4 | 3 | 4 | 1738215354054 | -1\n",
544-
"^Z3QWT29... | 2 | 4 | 5 | 1738215354054 | 1\n",
545-
"^3HN31E1... | 4 | 2 | 3 | 1738215354054 | 1\n",
546-
"^YYY4HAB... | 1 | 5 | 6 | 1738215354154 | 1\n",
547-
"^3CZ78B4... | 3 | 1 | 2 | 1738215354154 | 1\n",
548-
"^YYY4HAB... | 1 | 5 | 6 | 1738215354254 | -1\n",
549-
"^3CZ78B4... | 3 | 1 | 2 | 1738215354254 | -1\n",
550-
"^YYY4HAB... | 1 | 2 | 3 | 1738215354254 | 1\n",
551-
"^3CZ78B4... | 3 | 2 | 3 | 1738215354254 | 1\n"
540+
"^Z3QWT29... | 2 | 1 | 2 | 1738301923834 | 1\n",
541+
"^3HN31E1... | 4 | 3 | 4 | 1738301923834 | 1\n",
542+
"^Z3QWT29... | 2 | 1 | 2 | 1738301924136 | -1\n",
543+
"^3HN31E1... | 4 | 3 | 4 | 1738301924136 | -1\n",
544+
"^Z3QWT29... | 2 | 4 | 5 | 1738301924136 | 1\n",
545+
"^3HN31E1... | 4 | 2 | 3 | 1738301924136 | 1\n",
546+
"^YYY4HAB... | 1 | 5 | 6 | 1738301924236 | 1\n",
547+
"^3CZ78B4... | 3 | 1 | 2 | 1738301924236 | 1\n",
548+
"^YYY4HAB... | 1 | 5 | 6 | 1738301924336 | -1\n",
549+
"^3CZ78B4... | 3 | 1 | 2 | 1738301924336 | -1\n",
550+
"^YYY4HAB... | 1 | 2 | 3 | 1738301924336 | 1\n",
551+
"^3CZ78B4... | 3 | 2 | 3 | 1738301924336 | 1\n"
552552
]
553553
}
554554
],
@@ -581,16 +581,16 @@
581581
"output_type": "stream",
582582
"text": [
583583
" | group | value | ret | __time__ | __diff__\n",
584-
"^Z3QWT29... | 2 | 1 | 2 | 1738215355218 | 1\n",
585-
"^3CZ78B4... | 3 | 2 | 3 | 1738215355318 | 1\n",
586-
"^3HN31E1... | 4 | 3 | 4 | 1738215355420 | 1\n",
587-
"^Z3QWT29... | 2 | 1 | 2 | 1738215355520 | -1\n",
588-
"^3HN31E1... | 4 | 3 | 4 | 1738215355520 | -1\n",
589-
"^Z3QWT29... | 2 | 4 | 5 | 1738215355520 | 1\n",
590-
"^3HN31E1... | 4 | 2 | 3 | 1738215355520 | 1\n",
591-
"^YYY4HAB... | 1 | 5 | 6 | 1738215355620 | 1\n",
592-
"^YYY4HAB... | 1 | 5 | 6 | 1738215355720 | -1\n",
593-
"^YYY4HAB... | 1 | 2 | 3 | 1738215355720 | 1\n"
584+
"^Z3QWT29... | 2 | 1 | 2 | 1738301925300 | 1\n",
585+
"^3CZ78B4... | 3 | 2 | 3 | 1738301925400 | 1\n",
586+
"^3HN31E1... | 4 | 3 | 4 | 1738301925500 | 1\n",
587+
"^Z3QWT29... | 2 | 1 | 2 | 1738301925600 | -1\n",
588+
"^3HN31E1... | 4 | 3 | 4 | 1738301925600 | -1\n",
589+
"^Z3QWT29... | 2 | 4 | 5 | 1738301925600 | 1\n",
590+
"^3HN31E1... | 4 | 2 | 3 | 1738301925600 | 1\n",
591+
"^YYY4HAB... | 1 | 5 | 6 | 1738301925700 | 1\n",
592+
"^YYY4HAB... | 1 | 5 | 6 | 1738301925800 | -1\n",
593+
"^YYY4HAB... | 1 | 2 | 3 | 1738301925800 | 1\n"
594594
]
595595
}
596596
],
@@ -633,18 +633,18 @@
633633
"output_type": "stream",
634634
"text": [
635635
" | group | value | ret | __time__ | __diff__\n",
636-
"^YYY4HAB... | 1 | 5 | 6 | 1738215356686 | 1\n",
637-
"^Z3QWT29... | 2 | 1 | 2 | 1738215356686 | 1\n",
638-
"^3CZ78B4... | 3 | 1 | 2 | 1738215356686 | 1\n",
639-
"^3HN31E1... | 4 | 3 | 4 | 1738215356686 | 1\n",
640-
"^YYY4HAB... | 1 | 5 | 6 | 1738215357188 | -1\n",
641-
"^Z3QWT29... | 2 | 1 | 2 | 1738215357188 | -1\n",
642-
"^3CZ78B4... | 3 | 1 | 2 | 1738215357188 | -1\n",
643-
"^3HN31E1... | 4 | 3 | 4 | 1738215357188 | -1\n",
644-
"^YYY4HAB... | 1 | 2 | 3 | 1738215357188 | 1\n",
645-
"^Z3QWT29... | 2 | 4 | 5 | 1738215357188 | 1\n",
646-
"^3CZ78B4... | 3 | 2 | 3 | 1738215357188 | 1\n",
647-
"^3HN31E1... | 4 | 2 | 3 | 1738215357188 | 1\n"
636+
"^YYY4HAB... | 1 | 5 | 6 | 1738301926740 | 1\n",
637+
"^Z3QWT29... | 2 | 1 | 2 | 1738301926740 | 1\n",
638+
"^3CZ78B4... | 3 | 1 | 2 | 1738301926740 | 1\n",
639+
"^3HN31E1... | 4 | 3 | 4 | 1738301926740 | 1\n",
640+
"^YYY4HAB... | 1 | 5 | 6 | 1738301927240 | -1\n",
641+
"^Z3QWT29... | 2 | 1 | 2 | 1738301927240 | -1\n",
642+
"^3CZ78B4... | 3 | 1 | 2 | 1738301927240 | -1\n",
643+
"^3HN31E1... | 4 | 3 | 4 | 1738301927240 | -1\n",
644+
"^YYY4HAB... | 1 | 2 | 3 | 1738301927240 | 1\n",
645+
"^Z3QWT29... | 2 | 4 | 5 | 1738301927240 | 1\n",
646+
"^3CZ78B4... | 3 | 2 | 3 | 1738301927240 | 1\n",
647+
"^3HN31E1... | 4 | 2 | 3 | 1738301927240 | 1\n"
648648
]
649649
}
650650
],
@@ -688,16 +688,16 @@
688688
"output_type": "stream",
689689
"text": [
690690
" | group | value | ret | __time__ | __diff__\n",
691-
"^Z3QWT29... | 2 | 1 | 2 | 1738215358160 | 1\n",
692-
"^3HN31E1... | 4 | 3 | 4 | 1738215358160 | 1\n",
693-
"^Z3QWT29... | 2 | 1 | 2 | 1738215358460 | -1\n",
694-
"^3HN31E1... | 4 | 3 | 4 | 1738215358460 | -1\n",
695-
"^YYY4HAB... | 1 | 5 | 6 | 1738215358560 | 1\n",
696-
"^3CZ78B4... | 3 | 1 | 2 | 1738215358560 | 1\n",
697-
"^YYY4HAB... | 1 | 5 | 6 | 1738215358660 | -1\n",
698-
"^3CZ78B4... | 3 | 1 | 2 | 1738215358660 | -1\n",
699-
"^YYY4HAB... | 1 | 2 | 3 | 1738215358660 | 1\n",
700-
"^3CZ78B4... | 3 | 2 | 3 | 1738215358660 | 1\n"
691+
"^Z3QWT29... | 2 | 1 | 2 | 1738301928204 | 1\n",
692+
"^3HN31E1... | 4 | 3 | 4 | 1738301928204 | 1\n",
693+
"^Z3QWT29... | 2 | 1 | 2 | 1738301928506 | -1\n",
694+
"^3HN31E1... | 4 | 3 | 4 | 1738301928506 | -1\n",
695+
"^YYY4HAB... | 1 | 5 | 6 | 1738301928606 | 1\n",
696+
"^3CZ78B4... | 3 | 1 | 2 | 1738301928606 | 1\n",
697+
"^YYY4HAB... | 1 | 5 | 6 | 1738301928704 | -1\n",
698+
"^3CZ78B4... | 3 | 1 | 2 | 1738301928704 | -1\n",
699+
"^YYY4HAB... | 1 | 2 | 3 | 1738301928704 | 1\n",
700+
"^3CZ78B4... | 3 | 2 | 3 | 1738301928704 | 1\n"
701701
]
702702
}
703703
],

‎examples/notebooks/tutorials/consistency.ipynb‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -327,7 +327,7 @@
327327
"name": "stderr",
328328
"output_type": "stream",
329329
"text": [
330-
"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"
330+
"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"
331331
]
332332
},
333333
{

‎examples/notebooks/tutorials/udf.ipynb‎

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -893,13 +893,7 @@
893893
"inc_async(0.6) starting\n",
894894
"inc_async(2.0) starting\n",
895895
"inc_async(0.2) starting\n",
896-
"inc_async(1.2) starting\n"
897-
]
898-
},
899-
{
900-
"name": "stdout",
901-
"output_type": "stream",
902-
"text": [
896+
"inc_async(1.2) starting\n",
903897
"inc_async(0.2) finishing\n"
904898
]
905899
},

0 commit comments

Comments
 (0)