Skip to content

Commit 3a92f52

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: e9bf9de7ab79c234090230e5e691682d66dade81
1 parent 7110826 commit 3a92f52

3 files changed

Lines changed: 66 additions & 60 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 | 1770183113792 | 1\n",
166-
"^3CZ78B4... | 2 | 3 | 1770183113794 | 1\n",
167-
"^YYY4HAB... | 6 | 7 | 1770183114192 | 1\n",
168-
"^3HN31E1... | 6 | 7 | 1770183114194 | 1\n",
169-
"^X1MXHYY... | 12 | 13 | 1770183114792 | 1\n"
165+
"^Z3QWT29... | 2 | 3 | 1770269900324 | 1\n",
166+
"^3CZ78B4... | 2 | 3 | 1770269900326 | 1\n",
167+
"^YYY4HAB... | 6 | 7 | 1770269900724 | 1\n",
168+
"^3HN31E1... | 6 | 7 | 1770269900726 | 1\n",
169+
"^X1MXHYY... | 12 | 13 | 1770269901324 | 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 | 1770183118244 | 1\n",
414-
"^Z3QWT29... | 2 | 1 | 2 | 1770183118444 | -1\n",
415-
"^Z3QWT29... | 2 | 3 | 4 | 1770183118444 | 1\n",
416-
"^YYY4HAB... | 1 | 5 | 6 | 1770183118644 | 1\n",
417-
"^YYY4HAB... | 1 | 5 | 6 | 1770183118646 | -1\n",
418-
"^YYY4HAB... | 1 | 2 | 3 | 1770183118646 | 1\n"
413+
"^Z3QWT29... | 2 | 1 | 2 | 1770269904764 | 1\n",
414+
"^Z3QWT29... | 2 | 1 | 2 | 1770269904964 | -1\n",
415+
"^Z3QWT29... | 2 | 3 | 4 | 1770269904964 | 1\n",
416+
"^YYY4HAB... | 1 | 5 | 6 | 1770269905164 | 1\n",
417+
"^YYY4HAB... | 1 | 5 | 6 | 1770269905166 | -1\n",
418+
"^YYY4HAB... | 1 | 2 | 3 | 1770269905166 | 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 | 1770183119354 | 1\n",
541-
"^3HN31E1... | 4 | 3 | 4 | 1770183119354 | 1\n",
542-
"^Z3QWT29... | 2 | 1 | 2 | 1770183119454 | -1\n",
543-
"^3HN31E1... | 4 | 3 | 4 | 1770183119454 | -1\n",
544-
"^Z3QWT29... | 2 | 4 | 5 | 1770183119454 | 1\n",
545-
"^3HN31E1... | 4 | 2 | 3 | 1770183119454 | 1\n",
546-
"^YYY4HAB... | 1 | 5 | 6 | 1770183119554 | 1\n",
547-
"^3CZ78B4... | 3 | 1 | 2 | 1770183119554 | 1\n",
548-
"^YYY4HAB... | 1 | 5 | 6 | 1770183119556 | -1\n",
549-
"^3CZ78B4... | 3 | 1 | 2 | 1770183119556 | -1\n",
550-
"^YYY4HAB... | 1 | 2 | 3 | 1770183119556 | 1\n",
551-
"^3CZ78B4... | 3 | 2 | 3 | 1770183119556 | 1\n"
540+
"^Z3QWT29... | 2 | 1 | 2 | 1770269905908 | 1\n",
541+
"^3HN31E1... | 4 | 3 | 4 | 1770269905908 | 1\n",
542+
"^Z3QWT29... | 2 | 1 | 2 | 1770269906008 | -1\n",
543+
"^3HN31E1... | 4 | 3 | 4 | 1770269906008 | -1\n",
544+
"^Z3QWT29... | 2 | 4 | 5 | 1770269906008 | 1\n",
545+
"^3HN31E1... | 4 | 2 | 3 | 1770269906008 | 1\n",
546+
"^YYY4HAB... | 1 | 5 | 6 | 1770269906108 | 1\n",
547+
"^3CZ78B4... | 3 | 1 | 2 | 1770269906108 | 1\n",
548+
"^YYY4HAB... | 1 | 5 | 6 | 1770269906110 | -1\n",
549+
"^3CZ78B4... | 3 | 1 | 2 | 1770269906110 | -1\n",
550+
"^YYY4HAB... | 1 | 2 | 3 | 1770269906110 | 1\n",
551+
"^3CZ78B4... | 3 | 2 | 3 | 1770269906110 | 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 | 1770183119786 | 1\n",
585-
"^3CZ78B4... | 3 | 1 | 2 | 1770183119788 | 1\n",
586-
"^3CZ78B4... | 3 | 1 | 2 | 1770183119886 | -1\n",
587-
"^3CZ78B4... | 3 | 2 | 3 | 1770183119886 | 1\n",
588-
"^3HN31E1... | 4 | 3 | 4 | 1770183119984 | 1\n",
589-
"^3HN31E1... | 4 | 3 | 4 | 1770183119986 | -1\n",
590-
"^3HN31E1... | 4 | 2 | 3 | 1770183119986 | 1\n",
591-
"^Z3QWT29... | 2 | 1 | 2 | 1770183120084 | -1\n",
592-
"^Z3QWT29... | 2 | 4 | 5 | 1770183120084 | 1\n",
593-
"^YYY4HAB... | 1 | 5 | 6 | 1770183120186 | 1\n",
594-
"^YYY4HAB... | 1 | 5 | 6 | 1770183120188 | -1\n",
595-
"^YYY4HAB... | 1 | 2 | 3 | 1770183120188 | 1\n"
584+
"^Z3QWT29... | 2 | 1 | 2 | 1770269906320 | 1\n",
585+
"^3CZ78B4... | 3 | 1 | 2 | 1770269906322 | 1\n",
586+
"^3CZ78B4... | 3 | 1 | 2 | 1770269906420 | -1\n",
587+
"^3CZ78B4... | 3 | 2 | 3 | 1770269906420 | 1\n",
588+
"^3HN31E1... | 4 | 3 | 4 | 1770269906520 | 1\n",
589+
"^3HN31E1... | 4 | 3 | 4 | 1770269906522 | -1\n",
590+
"^3HN31E1... | 4 | 2 | 3 | 1770269906522 | 1\n",
591+
"^Z3QWT29... | 2 | 1 | 2 | 1770269906620 | -1\n",
592+
"^Z3QWT29... | 2 | 4 | 5 | 1770269906620 | 1\n",
593+
"^YYY4HAB... | 1 | 5 | 6 | 1770269906720 | 1\n",
594+
"^YYY4HAB... | 1 | 5 | 6 | 1770269906722 | -1\n",
595+
"^YYY4HAB... | 1 | 2 | 3 | 1770269906722 | 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 | 1770183120886 | 1\n",
639-
"^Z3QWT29... | 2 | 1 | 2 | 1770183120886 | 1\n",
640-
"^3CZ78B4... | 3 | 1 | 2 | 1770183120886 | 1\n",
641-
"^3HN31E1... | 4 | 3 | 4 | 1770183120886 | 1\n",
642-
"^YYY4HAB... | 1 | 5 | 6 | 1770183120888 | -1\n",
643-
"^Z3QWT29... | 2 | 1 | 2 | 1770183120888 | -1\n",
644-
"^3CZ78B4... | 3 | 1 | 2 | 1770183120888 | -1\n",
645-
"^3HN31E1... | 4 | 3 | 4 | 1770183120888 | -1\n",
646-
"^YYY4HAB... | 1 | 2 | 3 | 1770183120888 | 1\n",
647-
"^Z3QWT29... | 2 | 4 | 5 | 1770183120888 | 1\n",
648-
"^3CZ78B4... | 3 | 2 | 3 | 1770183120888 | 1\n",
649-
"^3HN31E1... | 4 | 2 | 3 | 1770183120888 | 1\n"
638+
"^YYY4HAB... | 1 | 5 | 6 | 1770269907402 | 1\n",
639+
"^Z3QWT29... | 2 | 1 | 2 | 1770269907402 | 1\n",
640+
"^3CZ78B4... | 3 | 1 | 2 | 1770269907402 | 1\n",
641+
"^3HN31E1... | 4 | 3 | 4 | 1770269907402 | 1\n",
642+
"^YYY4HAB... | 1 | 5 | 6 | 1770269907404 | -1\n",
643+
"^Z3QWT29... | 2 | 1 | 2 | 1770269907404 | -1\n",
644+
"^3CZ78B4... | 3 | 1 | 2 | 1770269907404 | -1\n",
645+
"^3HN31E1... | 4 | 3 | 4 | 1770269907404 | -1\n",
646+
"^YYY4HAB... | 1 | 2 | 3 | 1770269907404 | 1\n",
647+
"^Z3QWT29... | 2 | 4 | 5 | 1770269907404 | 1\n",
648+
"^3CZ78B4... | 3 | 2 | 3 | 1770269907404 | 1\n",
649+
"^3HN31E1... | 4 | 2 | 3 | 1770269907404 | 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 | 1770183121300 | 1\n",
694-
"^3HN31E1... | 4 | 3 | 4 | 1770183121300 | 1\n",
695-
"^Z3QWT29... | 2 | 1 | 2 | 1770183121402 | -1\n",
696-
"^3HN31E1... | 4 | 3 | 4 | 1770183121402 | -1\n",
697-
"^YYY4HAB... | 1 | 5 | 6 | 1770183121500 | 1\n",
698-
"^3CZ78B4... | 3 | 1 | 2 | 1770183121500 | 1\n",
699-
"^YYY4HAB... | 1 | 5 | 6 | 1770183121502 | -1\n",
700-
"^3CZ78B4... | 3 | 1 | 2 | 1770183121502 | -1\n",
701-
"^YYY4HAB... | 1 | 2 | 3 | 1770183121502 | 1\n",
702-
"^3CZ78B4... | 3 | 2 | 3 | 1770183121502 | 1\n"
693+
"^Z3QWT29... | 2 | 1 | 2 | 1770269907810 | 1\n",
694+
"^3HN31E1... | 4 | 3 | 4 | 1770269907810 | 1\n",
695+
"^Z3QWT29... | 2 | 1 | 2 | 1770269907912 | -1\n",
696+
"^3HN31E1... | 4 | 3 | 4 | 1770269907912 | -1\n",
697+
"^YYY4HAB... | 1 | 5 | 6 | 1770269908010 | 1\n",
698+
"^3CZ78B4... | 3 | 1 | 2 | 1770269908010 | 1\n",
699+
"^YYY4HAB... | 1 | 5 | 6 | 1770269908012 | -1\n",
700+
"^3CZ78B4... | 3 | 1 | 2 | 1770269908012 | -1\n",
701+
"^YYY4HAB... | 1 | 2 | 3 | 1770269908012 | 1\n",
702+
"^3CZ78B4... | 3 | 2 | 3 | 1770269908012 | 1\n"
703703
]
704704
}
705705
],

‎examples/notebooks/tutorials/consistency.ipynb‎

Lines changed: 2 additions & 2 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 1770183130868. 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 1770269917266. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n"
327327
]
328328
},
329329
{
@@ -541,7 +541,7 @@
541541
"source": [
542542
"You can observe that Pathway processed all the events intended to be simultaneous at the same time, and the sum of operations always equals 0.\n",
543543
"\n",
544-
"# Persistency guarantees\n",
544+
"## Persistency guarantees\n",
545545
"\n",
546546
"Pathway persists intermediate results recording the state of inputs with each saved datum. When restarted from a checkpoint, the saved state is loaded into memory first. Then all inputs are replayed starting at times recorded in the checkpoint. To avoid data loss, all streaming inputs should be buffered into a persistent message queue which allows multiple reads to recent items, such as a topic in Apache Kafka.\n",
547547
"\n",

‎examples/notebooks/tutorials/udf.ipynb‎

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -893,7 +893,13 @@
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",
896+
"inc_async(1.2) starting\n"
897+
]
898+
},
899+
{
900+
"name": "stdout",
901+
"output_type": "stream",
902+
"text": [
897903
"inc_async(0.2) finishing\n"
898904
]
899905
},

0 commit comments

Comments
 (0)