Skip to content

Commit a25bfe5

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: 8a01ce823b40a52d0205a5321ca90b9b5c88767f
1 parent 3175d53 commit a25bfe5

3 files changed

Lines changed: 72 additions & 69 deletions

File tree

‎examples/notebooks/tutorials/asynctransformer.ipynb‎

Lines changed: 57 additions & 57 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 | 1770095374478 | 1\n",
166-
"^3CZ78B4... | 2 | 3 | 1770095374480 | 1\n",
167-
"^YYY4HAB... | 6 | 7 | 1770095374880 | 1\n",
168-
"^3HN31E1... | 6 | 7 | 1770095374882 | 1\n",
169-
"^X1MXHYY... | 12 | 13 | 1770095375480 | 1\n"
165+
"^Z3QWT29... | 2 | 3 | 1770096706656 | 1\n",
166+
"^3CZ78B4... | 2 | 3 | 1770096706658 | 1\n",
167+
"^YYY4HAB... | 6 | 7 | 1770096707056 | 1\n",
168+
"^3HN31E1... | 6 | 7 | 1770096707058 | 1\n",
169+
"^X1MXHYY... | 12 | 13 | 1770096707656 | 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 | 1770095378944 | 1\n",
414-
"^Z3QWT29... | 2 | 1 | 2 | 1770095379144 | -1\n",
415-
"^Z3QWT29... | 2 | 3 | 4 | 1770095379144 | 1\n",
416-
"^YYY4HAB... | 1 | 5 | 6 | 1770095379344 | 1\n",
417-
"^YYY4HAB... | 1 | 5 | 6 | 1770095379346 | -1\n",
418-
"^YYY4HAB... | 1 | 2 | 3 | 1770095379346 | 1\n"
413+
"^Z3QWT29... | 2 | 1 | 2 | 1770096711570 | 1\n",
414+
"^Z3QWT29... | 2 | 1 | 2 | 1770096711770 | -1\n",
415+
"^Z3QWT29... | 2 | 3 | 4 | 1770096711770 | 1\n",
416+
"^YYY4HAB... | 1 | 5 | 6 | 1770096711970 | 1\n",
417+
"^YYY4HAB... | 1 | 5 | 6 | 1770096711972 | -1\n",
418+
"^YYY4HAB... | 1 | 2 | 3 | 1770096711972 | 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 | 1770095380074 | 1\n",
541-
"^3HN31E1... | 4 | 3 | 4 | 1770095380074 | 1\n",
542-
"^Z3QWT29... | 2 | 1 | 2 | 1770095380174 | -1\n",
543-
"^3HN31E1... | 4 | 3 | 4 | 1770095380174 | -1\n",
544-
"^Z3QWT29... | 2 | 4 | 5 | 1770095380174 | 1\n",
545-
"^3HN31E1... | 4 | 2 | 3 | 1770095380174 | 1\n",
546-
"^YYY4HAB... | 1 | 5 | 6 | 1770095380274 | 1\n",
547-
"^3CZ78B4... | 3 | 1 | 2 | 1770095380274 | 1\n",
548-
"^YYY4HAB... | 1 | 5 | 6 | 1770095380276 | -1\n",
549-
"^3CZ78B4... | 3 | 1 | 2 | 1770095380276 | -1\n",
550-
"^YYY4HAB... | 1 | 2 | 3 | 1770095380276 | 1\n",
551-
"^3CZ78B4... | 3 | 2 | 3 | 1770095380276 | 1\n"
540+
"^Z3QWT29... | 2 | 1 | 2 | 1770096712830 | 1\n",
541+
"^3HN31E1... | 4 | 3 | 4 | 1770096712830 | 1\n",
542+
"^Z3QWT29... | 2 | 1 | 2 | 1770096712930 | -1\n",
543+
"^3HN31E1... | 4 | 3 | 4 | 1770096712930 | -1\n",
544+
"^Z3QWT29... | 2 | 4 | 5 | 1770096712930 | 1\n",
545+
"^3HN31E1... | 4 | 2 | 3 | 1770096712930 | 1\n",
546+
"^YYY4HAB... | 1 | 5 | 6 | 1770096713030 | 1\n",
547+
"^3CZ78B4... | 3 | 1 | 2 | 1770096713030 | 1\n",
548+
"^YYY4HAB... | 1 | 5 | 6 | 1770096713032 | -1\n",
549+
"^3CZ78B4... | 3 | 1 | 2 | 1770096713032 | -1\n",
550+
"^YYY4HAB... | 1 | 2 | 3 | 1770096713032 | 1\n",
551+
"^3CZ78B4... | 3 | 2 | 3 | 1770096713032 | 1\n"
552552
]
553553
}
554554
],
@@ -581,18 +581,18 @@
581581
"output_type": "stream",
582582
"text": [
583583
" | group | value | ret | __time__ | __diff__\n",
584-
"^Z3QWT29... | 2 | 1 | 2 | 1770095380478 | 1\n",
585-
"^3CZ78B4... | 3 | 1 | 2 | 1770095380480 | 1\n",
586-
"^3CZ78B4... | 3 | 1 | 2 | 1770095380578 | -1\n",
587-
"^3CZ78B4... | 3 | 2 | 3 | 1770095380578 | 1\n",
588-
"^3HN31E1... | 4 | 3 | 4 | 1770095380678 | 1\n",
589-
"^3HN31E1... | 4 | 3 | 4 | 1770095380680 | -1\n",
590-
"^3HN31E1... | 4 | 2 | 3 | 1770095380680 | 1\n",
591-
"^Z3QWT29... | 2 | 1 | 2 | 1770095380778 | -1\n",
592-
"^Z3QWT29... | 2 | 4 | 5 | 1770095380778 | 1\n",
593-
"^YYY4HAB... | 1 | 5 | 6 | 1770095380878 | 1\n",
594-
"^YYY4HAB... | 1 | 5 | 6 | 1770095380880 | -1\n",
595-
"^YYY4HAB... | 1 | 2 | 3 | 1770095380880 | 1\n"
584+
"^Z3QWT29... | 2 | 1 | 2 | 1770096713260 | 1\n",
585+
"^3CZ78B4... | 3 | 1 | 2 | 1770096713262 | 1\n",
586+
"^3CZ78B4... | 3 | 1 | 2 | 1770096713360 | -1\n",
587+
"^3CZ78B4... | 3 | 2 | 3 | 1770096713360 | 1\n",
588+
"^3HN31E1... | 4 | 3 | 4 | 1770096713460 | 1\n",
589+
"^3HN31E1... | 4 | 3 | 4 | 1770096713462 | -1\n",
590+
"^3HN31E1... | 4 | 2 | 3 | 1770096713462 | 1\n",
591+
"^Z3QWT29... | 2 | 1 | 2 | 1770096713560 | -1\n",
592+
"^Z3QWT29... | 2 | 4 | 5 | 1770096713560 | 1\n",
593+
"^YYY4HAB... | 1 | 5 | 6 | 1770096713660 | 1\n",
594+
"^YYY4HAB... | 1 | 5 | 6 | 1770096713662 | -1\n",
595+
"^YYY4HAB... | 1 | 2 | 3 | 1770096713662 | 1\n"
596596
]
597597
}
598598
],
@@ -635,18 +635,18 @@
635635
"output_type": "stream",
636636
"text": [
637637
" | group | value | ret | __time__ | __diff__\n",
638-
"^YYY4HAB... | 1 | 5 | 6 | 1770095381480 | 1\n",
639-
"^Z3QWT29... | 2 | 1 | 2 | 1770095381480 | 1\n",
640-
"^3CZ78B4... | 3 | 1 | 2 | 1770095381480 | 1\n",
641-
"^3HN31E1... | 4 | 3 | 4 | 1770095381480 | 1\n",
642-
"^YYY4HAB... | 1 | 5 | 6 | 1770095381482 | -1\n",
643-
"^Z3QWT29... | 2 | 1 | 2 | 1770095381482 | -1\n",
644-
"^3CZ78B4... | 3 | 1 | 2 | 1770095381482 | -1\n",
645-
"^3HN31E1... | 4 | 3 | 4 | 1770095381482 | -1\n",
646-
"^YYY4HAB... | 1 | 2 | 3 | 1770095381482 | 1\n",
647-
"^Z3QWT29... | 2 | 4 | 5 | 1770095381482 | 1\n",
648-
"^3CZ78B4... | 3 | 2 | 3 | 1770095381482 | 1\n",
649-
"^3HN31E1... | 4 | 2 | 3 | 1770095381482 | 1\n"
638+
"^YYY4HAB... | 1 | 5 | 6 | 1770096715892 | 1\n",
639+
"^Z3QWT29... | 2 | 1 | 2 | 1770096715892 | 1\n",
640+
"^3CZ78B4... | 3 | 1 | 2 | 1770096715892 | 1\n",
641+
"^3HN31E1... | 4 | 3 | 4 | 1770096715892 | 1\n",
642+
"^YYY4HAB... | 1 | 5 | 6 | 1770096715894 | -1\n",
643+
"^Z3QWT29... | 2 | 1 | 2 | 1770096715894 | -1\n",
644+
"^3CZ78B4... | 3 | 1 | 2 | 1770096715894 | -1\n",
645+
"^3HN31E1... | 4 | 3 | 4 | 1770096715894 | -1\n",
646+
"^YYY4HAB... | 1 | 2 | 3 | 1770096715894 | 1\n",
647+
"^Z3QWT29... | 2 | 4 | 5 | 1770096715894 | 1\n",
648+
"^3CZ78B4... | 3 | 2 | 3 | 1770096715894 | 1\n",
649+
"^3HN31E1... | 4 | 2 | 3 | 1770096715894 | 1\n"
650650
]
651651
}
652652
],
@@ -690,16 +690,16 @@
690690
"output_type": "stream",
691691
"text": [
692692
" | group | value | ret | __time__ | __diff__\n",
693-
"^Z3QWT29... | 2 | 1 | 2 | 1770095381908 | 1\n",
694-
"^3HN31E1... | 4 | 3 | 4 | 1770095381908 | 1\n",
695-
"^Z3QWT29... | 2 | 1 | 2 | 1770095382008 | -1\n",
696-
"^3HN31E1... | 4 | 3 | 4 | 1770095382008 | -1\n",
697-
"^YYY4HAB... | 1 | 5 | 6 | 1770095382108 | 1\n",
698-
"^3CZ78B4... | 3 | 1 | 2 | 1770095382108 | 1\n",
699-
"^YYY4HAB... | 1 | 5 | 6 | 1770095382110 | -1\n",
700-
"^3CZ78B4... | 3 | 1 | 2 | 1770095382110 | -1\n",
701-
"^YYY4HAB... | 1 | 2 | 3 | 1770095382110 | 1\n",
702-
"^3CZ78B4... | 3 | 2 | 3 | 1770095382110 | 1\n"
693+
"^Z3QWT29... | 2 | 1 | 2 | 1770096716340 | 1\n",
694+
"^3HN31E1... | 4 | 3 | 4 | 1770096716340 | 1\n",
695+
"^Z3QWT29... | 2 | 1 | 2 | 1770096716442 | -1\n",
696+
"^3HN31E1... | 4 | 3 | 4 | 1770096716442 | -1\n",
697+
"^YYY4HAB... | 1 | 5 | 6 | 1770096716540 | 1\n",
698+
"^3CZ78B4... | 3 | 1 | 2 | 1770096716540 | 1\n",
699+
"^YYY4HAB... | 1 | 5 | 6 | 1770096716542 | -1\n",
700+
"^3CZ78B4... | 3 | 1 | 2 | 1770096716542 | -1\n",
701+
"^YYY4HAB... | 1 | 2 | 3 | 1770096716542 | 1\n",
702+
"^3CZ78B4... | 3 | 2 | 3 | 1770096716542 | 1\n"
703703
]
704704
}
705705
],

‎examples/notebooks/tutorials/consistency.ipynb‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -323,7 +323,7 @@
323323
"name": "stderr",
324324
"output_type": "stream",
325325
"text": [
326-
"INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 0 entries, time 1770095391956. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n"
326+
"INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 0 entries, time 1770096730020. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n"
327327
]
328328
},
329329
{
@@ -452,13 +452,6 @@
452452
"INFO:pathway_engine.connectors.monitoring:PythonReader: 10 entries (3 minibatch(es)) have been sent to the engine\n"
453453
]
454454
},
455-
{
456-
"name": "stderr",
457-
"output_type": "stream",
458-
"text": [
459-
"WARNING:pathway_engine.connectors.monitoring:PythonReader: Closing the data source\n"
460-
]
461-
},
462455
{
463456
"name": "stderr",
464457
"output_type": "stream",
@@ -522,6 +515,13 @@
522515
"INFO:root:Total: 0\n"
523516
]
524517
},
518+
{
519+
"name": "stderr",
520+
"output_type": "stream",
521+
"text": [
522+
"WARNING:pathway_engine.connectors.monitoring:PythonReader: Closing the data source\n"
523+
]
524+
},
525525
{
526526
"name": "stderr",
527527
"output_type": "stream",

‎examples/notebooks/tutorials/udf.ipynb‎

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -787,9 +787,6 @@
787787
"name": "stdout",
788788
"output_type": "stream",
789789
"text": [
790-
"inc(2)\n",
791-
"inc(13)\n",
792-
"inc(1)\n",
793790
" | value | value_inc\n",
794791
"^X1MXHYY... | 1 | 2\n",
795792
"^3CZ78B4... | 1 | 2\n",
@@ -896,7 +893,13 @@
896893
"inc_async(0.6) starting\n",
897894
"inc_async(2.0) starting\n",
898895
"inc_async(0.2) starting\n",
899-
"inc_async(1.2) starting\n",
896+
"inc_async(1.2) starting\n"
897+
]
898+
},
899+
{
900+
"name": "stdout",
901+
"output_type": "stream",
902+
"text": [
900903
"inc_async(0.2) finishing\n"
901904
]
902905
},

0 commit comments

Comments
 (0)