Skip to content

Commit 81a03d7

Browse files
Pathway-DevManul from Pathway
Pathway-Dev
and
Manul from Pathway
committed
Daily Pathway examples refresh
Co-authored-by: Manul from Pathway <[email protected]> GitOrigin-RevId: 47da9b7a82bb5038d79365fc71fd11b2e94eb1ff
1 parent 6deea3f commit 81a03d7

File tree

3 files changed

+37
-43
lines changed

3 files changed

+37
-43
lines changed

Diff for: ‎examples/notebooks/tutorials/asynctransformer.ipynb

+35-35
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 | 1743309251836 | 1\n",
166-
"^3CZ78B4... | 2 | 3 | 1743309251836 | 1\n",
167-
"^YYY4HAB... | 6 | 7 | 1743309252238 | 1\n",
168-
"^3HN31E1... | 6 | 7 | 1743309252238 | 1\n",
169-
"^X1MXHYY... | 12 | 13 | 1743309252838 | 1\n"
165+
"^Z3QWT29... | 2 | 3 | 1743395618778 | 1\n",
166+
"^3CZ78B4... | 2 | 3 | 1743395618778 | 1\n",
167+
"^YYY4HAB... | 6 | 7 | 1743395619178 | 1\n",
168+
"^3HN31E1... | 6 | 7 | 1743395619178 | 1\n",
169+
"^X1MXHYY... | 12 | 13 | 1743395619778 | 1\n"
170170
]
171171
}
172172
],
@@ -410,10 +410,10 @@
410410
"output_type": "stream",
411411
"text": [
412412
" | group | value | ret | __time__ | __diff__\n",
413-
"^Z3QWT29... | 2 | 1 | 2 | 1743309261432 | 1\n",
414-
"^Z3QWT29... | 2 | 1 | 2 | 1743309261632 | -1\n",
415-
"^Z3QWT29... | 2 | 3 | 4 | 1743309261632 | 1\n",
416-
"^YYY4HAB... | 1 | 2 | 3 | 1743309261832 | 1\n"
413+
"^Z3QWT29... | 2 | 1 | 2 | 1743395628382 | 1\n",
414+
"^Z3QWT29... | 2 | 1 | 2 | 1743395628582 | -1\n",
415+
"^Z3QWT29... | 2 | 3 | 4 | 1743395628582 | 1\n",
416+
"^YYY4HAB... | 1 | 2 | 3 | 1743395628782 | 1\n"
417417
]
418418
}
419419
],
@@ -535,14 +535,14 @@
535535
"output_type": "stream",
536536
"text": [
537537
" | group | value | ret | __time__ | __diff__\n",
538-
"^Z3QWT29... | 2 | 1 | 2 | 1743309264048 | 1\n",
539-
"^3HN31E1... | 4 | 3 | 4 | 1743309264048 | 1\n",
540-
"^Z3QWT29... | 2 | 1 | 2 | 1743309264148 | -1\n",
541-
"^3HN31E1... | 4 | 3 | 4 | 1743309264148 | -1\n",
542-
"^Z3QWT29... | 2 | 4 | 5 | 1743309264148 | 1\n",
543-
"^3HN31E1... | 4 | 2 | 3 | 1743309264148 | 1\n",
544-
"^YYY4HAB... | 1 | 2 | 3 | 1743309264248 | 1\n",
545-
"^3CZ78B4... | 3 | 2 | 3 | 1743309264248 | 1\n"
538+
"^Z3QWT29... | 2 | 1 | 2 | 1743395630976 | 1\n",
539+
"^3HN31E1... | 4 | 3 | 4 | 1743395630976 | 1\n",
540+
"^Z3QWT29... | 2 | 1 | 2 | 1743395631076 | -1\n",
541+
"^3HN31E1... | 4 | 3 | 4 | 1743395631076 | -1\n",
542+
"^Z3QWT29... | 2 | 4 | 5 | 1743395631076 | 1\n",
543+
"^3HN31E1... | 4 | 2 | 3 | 1743395631076 | 1\n",
544+
"^YYY4HAB... | 1 | 2 | 3 | 1743395631176 | 1\n",
545+
"^3CZ78B4... | 3 | 2 | 3 | 1743395631176 | 1\n"
546546
]
547547
}
548548
],
@@ -575,14 +575,14 @@
575575
"output_type": "stream",
576576
"text": [
577577
" | group | value | ret | __time__ | __diff__\n",
578-
"^Z3QWT29... | 2 | 1 | 2 | 1743309265306 | 1\n",
579-
"^3CZ78B4... | 3 | 1 | 2 | 1743309265306 | 1\n",
580-
"^3CZ78B4... | 3 | 1 | 2 | 1743309265406 | -1\n",
581-
"^3CZ78B4... | 3 | 2 | 3 | 1743309265406 | 1\n",
582-
"^3HN31E1... | 4 | 2 | 3 | 1743309265506 | 1\n",
583-
"^Z3QWT29... | 2 | 1 | 2 | 1743309265606 | -1\n",
584-
"^Z3QWT29... | 2 | 4 | 5 | 1743309265606 | 1\n",
585-
"^YYY4HAB... | 1 | 2 | 3 | 1743309265706 | 1\n"
578+
"^Z3QWT29... | 2 | 1 | 2 | 1743395632220 | 1\n",
579+
"^3CZ78B4... | 3 | 1 | 2 | 1743395632220 | 1\n",
580+
"^3CZ78B4... | 3 | 1 | 2 | 1743395632320 | -1\n",
581+
"^3CZ78B4... | 3 | 2 | 3 | 1743395632320 | 1\n",
582+
"^3HN31E1... | 4 | 2 | 3 | 1743395632422 | 1\n",
583+
"^Z3QWT29... | 2 | 1 | 2 | 1743395632522 | -1\n",
584+
"^Z3QWT29... | 2 | 4 | 5 | 1743395632522 | 1\n",
585+
"^YYY4HAB... | 1 | 2 | 3 | 1743395632620 | 1\n"
586586
]
587587
}
588588
],
@@ -625,10 +625,10 @@
625625
"output_type": "stream",
626626
"text": [
627627
" | group | value | ret | __time__ | __diff__\n",
628-
"^YYY4HAB... | 1 | 2 | 3 | 1743309267166 | 1\n",
629-
"^Z3QWT29... | 2 | 4 | 5 | 1743309267166 | 1\n",
630-
"^3CZ78B4... | 3 | 2 | 3 | 1743309267166 | 1\n",
631-
"^3HN31E1... | 4 | 2 | 3 | 1743309267166 | 1\n"
628+
"^YYY4HAB... | 1 | 2 | 3 | 1743395634064 | 1\n",
629+
"^Z3QWT29... | 2 | 4 | 5 | 1743395634064 | 1\n",
630+
"^3CZ78B4... | 3 | 2 | 3 | 1743395634064 | 1\n",
631+
"^3HN31E1... | 4 | 2 | 3 | 1743395634064 | 1\n"
632632
]
633633
}
634634
],
@@ -672,12 +672,12 @@
672672
"output_type": "stream",
673673
"text": [
674674
" | group | value | ret | __time__ | __diff__\n",
675-
"^Z3QWT29... | 2 | 1 | 2 | 1743309268424 | 1\n",
676-
"^3HN31E1... | 4 | 3 | 4 | 1743309268424 | 1\n",
677-
"^Z3QWT29... | 2 | 1 | 2 | 1743309268524 | -1\n",
678-
"^3HN31E1... | 4 | 3 | 4 | 1743309268524 | -1\n",
679-
"^YYY4HAB... | 1 | 2 | 3 | 1743309268624 | 1\n",
680-
"^3CZ78B4... | 3 | 2 | 3 | 1743309268624 | 1\n"
675+
"^Z3QWT29... | 2 | 1 | 2 | 1743395635318 | 1\n",
676+
"^3HN31E1... | 4 | 3 | 4 | 1743395635318 | 1\n",
677+
"^Z3QWT29... | 2 | 1 | 2 | 1743395635418 | -1\n",
678+
"^3HN31E1... | 4 | 3 | 4 | 1743395635418 | -1\n",
679+
"^YYY4HAB... | 1 | 2 | 3 | 1743395635516 | 1\n",
680+
"^3CZ78B4... | 3 | 2 | 3 | 1743395635516 | 1\n"
681681
]
682682
}
683683
],

Diff for: ‎examples/notebooks/tutorials/consistency.ipynb

+1-1
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 1743309488408. 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 1743395854868. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n"
327327
]
328328
},
329329
{

Diff for: ‎examples/notebooks/tutorials/udf.ipynb

+1-7
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)