Skip to content

Commit 2a7dca6

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: f74a7ec6f5b54088e4899ce4fc8c0563bbe9e29e
1 parent 45ffee2 commit 2a7dca6

2 files changed

Lines changed: 77 additions & 77 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 | 1776850501586 | 1\n",
166-
"^3CZ78B4... | 2 | 3 | 1776850501588 | 1\n",
167-
"^YYY4HAB... | 6 | 7 | 1776850501988 | 1\n",
168-
"^3HN31E1... | 6 | 7 | 1776850501990 | 1\n",
169-
"^X1MXHYY... | 12 | 13 | 1776850502586 | 1\n"
165+
"^Z3QWT29... | 2 | 3 | 1776918772266 | 1\n",
166+
"^3CZ78B4... | 2 | 3 | 1776918772268 | 1\n",
167+
"^YYY4HAB... | 6 | 7 | 1776918772666 | 1\n",
168+
"^3HN31E1... | 6 | 7 | 1776918772668 | 1\n",
169+
"^X1MXHYY... | 12 | 13 | 1776918773266 | 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 | 1776850507830 | 1\n",
414-
"^Z3QWT29... | 2 | 1 | 2 | 1776850508032 | -1\n",
415-
"^Z3QWT29... | 2 | 3 | 4 | 1776850508032 | 1\n",
416-
"^YYY4HAB... | 1 | 5 | 6 | 1776850508230 | 1\n",
417-
"^YYY4HAB... | 1 | 5 | 6 | 1776850508232 | -1\n",
418-
"^YYY4HAB... | 1 | 2 | 3 | 1776850508232 | 1\n"
413+
"^Z3QWT29... | 2 | 1 | 2 | 1776918776790 | 1\n",
414+
"^Z3QWT29... | 2 | 1 | 2 | 1776918776990 | -1\n",
415+
"^Z3QWT29... | 2 | 3 | 4 | 1776918776990 | 1\n",
416+
"^YYY4HAB... | 1 | 5 | 6 | 1776918777192 | 1\n",
417+
"^YYY4HAB... | 1 | 5 | 6 | 1776918777194 | -1\n",
418+
"^YYY4HAB... | 1 | 2 | 3 | 1776918777194 | 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 | 1776850509052 | 1\n",
541-
"^3HN31E1... | 4 | 3 | 4 | 1776850509052 | 1\n",
542-
"^Z3QWT29... | 2 | 1 | 2 | 1776850509152 | -1\n",
543-
"^3HN31E1... | 4 | 3 | 4 | 1776850509152 | -1\n",
544-
"^Z3QWT29... | 2 | 4 | 5 | 1776850509152 | 1\n",
545-
"^3HN31E1... | 4 | 2 | 3 | 1776850509152 | 1\n",
546-
"^YYY4HAB... | 1 | 5 | 6 | 1776850509252 | 1\n",
547-
"^3CZ78B4... | 3 | 1 | 2 | 1776850509252 | 1\n",
548-
"^YYY4HAB... | 1 | 5 | 6 | 1776850509254 | -1\n",
549-
"^3CZ78B4... | 3 | 1 | 2 | 1776850509254 | -1\n",
550-
"^YYY4HAB... | 1 | 2 | 3 | 1776850509254 | 1\n",
551-
"^3CZ78B4... | 3 | 2 | 3 | 1776850509254 | 1\n"
540+
"^Z3QWT29... | 2 | 1 | 2 | 1776918777934 | 1\n",
541+
"^3HN31E1... | 4 | 3 | 4 | 1776918777934 | 1\n",
542+
"^Z3QWT29... | 2 | 1 | 2 | 1776918778034 | -1\n",
543+
"^3HN31E1... | 4 | 3 | 4 | 1776918778034 | -1\n",
544+
"^Z3QWT29... | 2 | 4 | 5 | 1776918778034 | 1\n",
545+
"^3HN31E1... | 4 | 2 | 3 | 1776918778034 | 1\n",
546+
"^YYY4HAB... | 1 | 5 | 6 | 1776918778134 | 1\n",
547+
"^3CZ78B4... | 3 | 1 | 2 | 1776918778134 | 1\n",
548+
"^YYY4HAB... | 1 | 5 | 6 | 1776918778136 | -1\n",
549+
"^3CZ78B4... | 3 | 1 | 2 | 1776918778136 | -1\n",
550+
"^YYY4HAB... | 1 | 2 | 3 | 1776918778136 | 1\n",
551+
"^3CZ78B4... | 3 | 2 | 3 | 1776918778136 | 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 | 1776850509470 | 1\n",
585-
"^3CZ78B4... | 3 | 1 | 2 | 1776850509472 | 1\n",
586-
"^3CZ78B4... | 3 | 1 | 2 | 1776850509570 | -1\n",
587-
"^3CZ78B4... | 3 | 2 | 3 | 1776850509570 | 1\n",
588-
"^3HN31E1... | 4 | 3 | 4 | 1776850509670 | 1\n",
589-
"^3HN31E1... | 4 | 3 | 4 | 1776850509672 | -1\n",
590-
"^3HN31E1... | 4 | 2 | 3 | 1776850509672 | 1\n",
591-
"^Z3QWT29... | 2 | 1 | 2 | 1776850509770 | -1\n",
592-
"^Z3QWT29... | 2 | 4 | 5 | 1776850509770 | 1\n",
593-
"^YYY4HAB... | 1 | 5 | 6 | 1776850509870 | 1\n",
594-
"^YYY4HAB... | 1 | 5 | 6 | 1776850509872 | -1\n",
595-
"^YYY4HAB... | 1 | 2 | 3 | 1776850509872 | 1\n"
584+
"^Z3QWT29... | 2 | 1 | 2 | 1776918778338 | 1\n",
585+
"^3CZ78B4... | 3 | 1 | 2 | 1776918778340 | 1\n",
586+
"^3CZ78B4... | 3 | 1 | 2 | 1776918778440 | -1\n",
587+
"^3CZ78B4... | 3 | 2 | 3 | 1776918778440 | 1\n",
588+
"^3HN31E1... | 4 | 3 | 4 | 1776918778540 | 1\n",
589+
"^3HN31E1... | 4 | 3 | 4 | 1776918778542 | -1\n",
590+
"^3HN31E1... | 4 | 2 | 3 | 1776918778542 | 1\n",
591+
"^Z3QWT29... | 2 | 1 | 2 | 1776918778640 | -1\n",
592+
"^Z3QWT29... | 2 | 4 | 5 | 1776918778640 | 1\n",
593+
"^YYY4HAB... | 1 | 5 | 6 | 1776918778738 | 1\n",
594+
"^YYY4HAB... | 1 | 5 | 6 | 1776918778740 | -1\n",
595+
"^YYY4HAB... | 1 | 2 | 3 | 1776918778740 | 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 | 1776850510592 | 1\n",
639-
"^Z3QWT29... | 2 | 1 | 2 | 1776850510592 | 1\n",
640-
"^3CZ78B4... | 3 | 1 | 2 | 1776850510592 | 1\n",
641-
"^3HN31E1... | 4 | 3 | 4 | 1776850510592 | 1\n",
642-
"^YYY4HAB... | 1 | 5 | 6 | 1776850510594 | -1\n",
643-
"^Z3QWT29... | 2 | 1 | 2 | 1776850510594 | -1\n",
644-
"^3CZ78B4... | 3 | 1 | 2 | 1776850510594 | -1\n",
645-
"^3HN31E1... | 4 | 3 | 4 | 1776850510594 | -1\n",
646-
"^YYY4HAB... | 1 | 2 | 3 | 1776850510594 | 1\n",
647-
"^Z3QWT29... | 2 | 4 | 5 | 1776850510594 | 1\n",
648-
"^3CZ78B4... | 3 | 2 | 3 | 1776850510594 | 1\n",
649-
"^3HN31E1... | 4 | 2 | 3 | 1776850510594 | 1\n"
638+
"^YYY4HAB... | 1 | 5 | 6 | 1776918779416 | 1\n",
639+
"^Z3QWT29... | 2 | 1 | 2 | 1776918779416 | 1\n",
640+
"^3CZ78B4... | 3 | 1 | 2 | 1776918779416 | 1\n",
641+
"^3HN31E1... | 4 | 3 | 4 | 1776918779416 | 1\n",
642+
"^YYY4HAB... | 1 | 5 | 6 | 1776918779418 | -1\n",
643+
"^Z3QWT29... | 2 | 1 | 2 | 1776918779418 | -1\n",
644+
"^3CZ78B4... | 3 | 1 | 2 | 1776918779418 | -1\n",
645+
"^3HN31E1... | 4 | 3 | 4 | 1776918779418 | -1\n",
646+
"^YYY4HAB... | 1 | 2 | 3 | 1776918779418 | 1\n",
647+
"^Z3QWT29... | 2 | 4 | 5 | 1776918779418 | 1\n",
648+
"^3CZ78B4... | 3 | 2 | 3 | 1776918779418 | 1\n",
649+
"^3HN31E1... | 4 | 2 | 3 | 1776918779418 | 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 | 1776850512548 | 1\n",
694-
"^3HN31E1... | 4 | 3 | 4 | 1776850512548 | 1\n",
695-
"^Z3QWT29... | 2 | 1 | 2 | 1776850512648 | -1\n",
696-
"^3HN31E1... | 4 | 3 | 4 | 1776850512648 | -1\n",
697-
"^YYY4HAB... | 1 | 5 | 6 | 1776850512748 | 1\n",
698-
"^3CZ78B4... | 3 | 1 | 2 | 1776850512748 | 1\n",
699-
"^YYY4HAB... | 1 | 5 | 6 | 1776850512750 | -1\n",
700-
"^3CZ78B4... | 3 | 1 | 2 | 1776850512750 | -1\n",
701-
"^YYY4HAB... | 1 | 2 | 3 | 1776850512750 | 1\n",
702-
"^3CZ78B4... | 3 | 2 | 3 | 1776850512750 | 1\n"
693+
"^Z3QWT29... | 2 | 1 | 2 | 1776918779834 | 1\n",
694+
"^3HN31E1... | 4 | 3 | 4 | 1776918779834 | 1\n",
695+
"^Z3QWT29... | 2 | 1 | 2 | 1776918779934 | -1\n",
696+
"^3HN31E1... | 4 | 3 | 4 | 1776918779934 | -1\n",
697+
"^YYY4HAB... | 1 | 5 | 6 | 1776918780034 | 1\n",
698+
"^3CZ78B4... | 3 | 1 | 2 | 1776918780034 | 1\n",
699+
"^YYY4HAB... | 1 | 5 | 6 | 1776918780036 | -1\n",
700+
"^3CZ78B4... | 3 | 1 | 2 | 1776918780036 | -1\n",
701+
"^YYY4HAB... | 1 | 2 | 3 | 1776918780036 | 1\n",
702+
"^3CZ78B4... | 3 | 2 | 3 | 1776918780036 | 1\n"
703703
]
704704
}
705705
],

‎examples/notebooks/tutorials/consistency.ipynb‎

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -316,63 +316,63 @@
316316
"name": "stderr",
317317
"output_type": "stream",
318318
"text": [
319-
"INFO:pathway_engine.connectors:Realtime data starts from the time Timestamp(1776850531206)\n"
319+
"INFO:pathway_engine.connectors:Realtime data starts from the time Timestamp(1776918789810)\n"
320320
]
321321
},
322322
{
323323
"name": "stderr",
324324
"output_type": "stream",
325325
"text": [
326-
"INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 0 entries, time 1776850531206. 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 1776918789810. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n"
327327
]
328328
},
329329
{
330330
"name": "stderr",
331331
"output_type": "stream",
332332
"text": [
333-
"INFO:root:Account 1 balance: 60\n"
333+
"INFO:pathway_engine.connectors.monitoring:PythonReader: 4 entries (1 minibatch(es)) have been sent to the engine\n"
334334
]
335335
},
336336
{
337337
"name": "stderr",
338338
"output_type": "stream",
339339
"text": [
340-
"INFO:root:Account 4 balance: -72\n"
340+
"INFO:root:Account 1 balance: 60\n"
341341
]
342342
},
343343
{
344344
"name": "stderr",
345345
"output_type": "stream",
346346
"text": [
347-
"INFO:root:Account 2 balance: -76\n"
347+
"INFO:root:Account 4 balance: -72\n"
348348
]
349349
},
350350
{
351351
"name": "stderr",
352352
"output_type": "stream",
353353
"text": [
354-
"INFO:root:Account 7 balance: 29\n"
354+
"INFO:root:Account 2 balance: -76\n"
355355
]
356356
},
357357
{
358358
"name": "stderr",
359359
"output_type": "stream",
360360
"text": [
361-
"INFO:root:Account 9 balance: 59\n"
361+
"INFO:root:Account 7 balance: 29\n"
362362
]
363363
},
364364
{
365365
"name": "stderr",
366366
"output_type": "stream",
367367
"text": [
368-
"INFO:root:Total: 0\n"
368+
"INFO:root:Account 9 balance: 59\n"
369369
]
370370
},
371371
{
372372
"name": "stderr",
373373
"output_type": "stream",
374374
"text": [
375-
"INFO:pathway_engine.connectors.monitoring:PythonReader: 4 entries (1 minibatch(es)) have been sent to the engine\n"
375+
"INFO:root:Total: 0\n"
376376
]
377377
},
378378
{
@@ -456,77 +456,77 @@
456456
"name": "stderr",
457457
"output_type": "stream",
458458
"text": [
459-
"INFO:root:Removing account 1 balance: 158\n"
459+
"INFO:pathway_engine.connectors.monitoring:PythonReader: 6 entries (2 minibatch(es)) have been sent to the engine\n"
460460
]
461461
},
462462
{
463463
"name": "stderr",
464464
"output_type": "stream",
465465
"text": [
466-
"INFO:root:Removing account 9 balance: 59\n"
466+
"WARNING:pathway_engine.connectors.monitoring:PythonReader: Closing the data source\n"
467467
]
468468
},
469469
{
470470
"name": "stderr",
471471
"output_type": "stream",
472472
"text": [
473-
"INFO:root:Removing account 2 balance: -30\n"
473+
"INFO:root:Removing account 1 balance: 158\n"
474474
]
475475
},
476476
{
477477
"name": "stderr",
478478
"output_type": "stream",
479479
"text": [
480-
"INFO:root:Removing account 5 balance: -98\n"
480+
"INFO:root:Removing account 9 balance: 59\n"
481481
]
482482
},
483483
{
484484
"name": "stderr",
485485
"output_type": "stream",
486486
"text": [
487-
"INFO:root:Account 5 balance: -192\n"
487+
"INFO:root:Removing account 2 balance: -30\n"
488488
]
489489
},
490490
{
491491
"name": "stderr",
492492
"output_type": "stream",
493493
"text": [
494-
"INFO:root:Account 2 balance: 19\n"
494+
"INFO:root:Removing account 5 balance: -98\n"
495495
]
496496
},
497497
{
498498
"name": "stderr",
499499
"output_type": "stream",
500500
"text": [
501-
"INFO:root:Account 9 balance: 10\n"
501+
"INFO:root:Account 5 balance: -192\n"
502502
]
503503
},
504504
{
505505
"name": "stderr",
506506
"output_type": "stream",
507507
"text": [
508-
"INFO:root:Account 1 balance: 252\n"
508+
"INFO:root:Account 2 balance: 19\n"
509509
]
510510
},
511511
{
512512
"name": "stderr",
513513
"output_type": "stream",
514514
"text": [
515-
"INFO:root:Total: 0\n"
515+
"INFO:root:Account 9 balance: 10\n"
516516
]
517517
},
518518
{
519519
"name": "stderr",
520520
"output_type": "stream",
521521
"text": [
522-
"INFO:pathway_engine.connectors.monitoring:PythonReader: 6 entries (2 minibatch(es)) have been sent to the engine\n"
522+
"INFO:root:Account 1 balance: 252\n"
523523
]
524524
},
525525
{
526526
"name": "stderr",
527527
"output_type": "stream",
528528
"text": [
529-
"WARNING:pathway_engine.connectors.monitoring:PythonReader: Closing the data source\n"
529+
"INFO:root:Total: 0\n"
530530
]
531531
},
532532
{

0 commit comments

Comments
 (0)