Skip to content

Commit

Permalink
Daily Pathway examples refresh
Browse files Browse the repository at this point in the history 
Co-authored-by: Manul from Pathway <[email protected]>
GitOrigin-RevId: 77ecfaacbd3c2c4c7c58be1a7521b94339ff7a66
  • Loading branch information
@Pathway-Dev
Pathway-Dev and Manul from Pathway committed Mar 8, 2025
1 parent 4ef8258 commit 17e0d9f
Show file tree
Hide file tree
Showing 2 changed files with 36 additions and 36 deletions.
70 changes: 35 additions & 35 deletions examples/notebooks/tutorials/asynctransformer.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -162,11 +162,11 @@
"output_type": "stream",
"text": [
" | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 3 | 1741325601406 | 1\n",
"^3CZ78B4... | 2 | 3 | 1741325601406 | 1\n",
"^YYY4HAB... | 6 | 7 | 1741325601806 | 1\n",
"^3HN31E1... | 6 | 7 | 1741325601806 | 1\n",
"^X1MXHYY... | 12 | 13 | 1741325602406 | 1\n"
"^Z3QWT29... | 2 | 3 | 1741412150690 | 1\n",
"^3CZ78B4... | 2 | 3 | 1741412150690 | 1\n",
"^YYY4HAB... | 6 | 7 | 1741412151092 | 1\n",
"^3HN31E1... | 6 | 7 | 1741412151092 | 1\n",
"^X1MXHYY... | 12 | 13 | 1741412151692 | 1\n"
]
}
],
Expand Down Expand Up @@ -410,10 +410,10 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741325610972 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741325611172 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1741325611172 | 1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741325611372 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1741412160264 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741412160464 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1741412160464 | 1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741412160664 | 1\n"
]
}
],
Expand Down Expand Up @@ -535,14 +535,14 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741325613568 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1741325613568 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741325613668 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1741325613668 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1741325613668 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1741325613668 | 1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741325613768 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1741325613768 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1741412162864 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1741412162864 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741412162964 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1741412162964 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1741412162964 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1741412162964 | 1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741412163062 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1741412163062 | 1\n"
]
}
],
Expand Down Expand Up @@ -575,14 +575,14 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741325614808 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1741325614810 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1741325614910 | -1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1741325614910 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1741325615010 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741325615110 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1741325615110 | 1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741325615208 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1741412164144 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1741412164144 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1741412164246 | -1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1741412164246 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1741412164346 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741412164446 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1741412164446 | 1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741412164544 | 1\n"
]
}
],
Expand Down Expand Up @@ -625,10 +625,10 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741325616682 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1741325616682 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1741325616682 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1741325616682 | 1\n"
"^YYY4HAB... | 1 | 2 | 3 | 1741412165992 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1741412165992 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1741412165992 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1741412165992 | 1\n"
]
}
],
Expand Down Expand Up @@ -672,12 +672,12 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741325617944 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1741325617944 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741325618044 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1741325618044 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741325618142 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1741325618142 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1741412167234 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1741412167234 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1741412167334 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1741412167334 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1741412167434 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1741412167434 | 1\n"
]
}
],
Expand Down
2 changes: 1 addition & 1 deletion examples/notebooks/tutorials/consistency.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -323,7 +323,7 @@
"name": "stderr",
"output_type": "stream",
"text": [
"INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 0 entries, time 1741325837406. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n"
"INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 0 entries, time 1741412386936. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n"
]
},
{
Expand Down

0 comments on commit 17e0d9f

Please sign in to comment.