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: b7965d924a38eb1a32426cae624490f6280252b7
  • Loading branch information
@Pathway-Dev
Pathway-Dev and Manul from Pathway committed Dec 9, 2024
1 parent b35e731 commit 450e983
Showing 1 changed file with 55 additions and 55 deletions.
110 changes: 55 additions & 55 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 | 1733635969452 | 1\n",
"^3CZ78B4... | 2 | 3 | 1733635969654 | 1\n",
"^YYY4HAB... | 6 | 7 | 1733635969654 | 1\n",
"^3HN31E1... | 6 | 7 | 1733635970054 | 1\n",
"^X1MXHYY... | 12 | 13 | 1733635970054 | 1\n"
"^Z3QWT29... | 2 | 3 | 1733722373406 | 1\n",
"^3CZ78B4... | 2 | 3 | 1733722373606 | 1\n",
"^YYY4HAB... | 6 | 7 | 1733722373606 | 1\n",
"^3HN31E1... | 6 | 7 | 1733722374006 | 1\n",
"^X1MXHYY... | 12 | 13 | 1733722374006 | 1\n"
]
}
],
Expand Down Expand Up @@ -410,12 +410,12 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635973372 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635973472 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1733635973472 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635973672 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635973872 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733635973872 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1733722377356 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733722377456 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1733722377456 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722377658 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722377858 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733722377858 | 1\n"
]
}
],
Expand Down Expand Up @@ -537,18 +537,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635974116 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733635974116 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635974418 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733635974418 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1733635974418 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1733635974418 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635974518 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733635974518 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635974618 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733635974618 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733635974618 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1733635974618 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1733722378098 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733722378098 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733722378400 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733722378400 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1733722378400 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1733722378400 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722378498 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733722378498 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722378598 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733722378598 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733722378598 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1733722378598 | 1\n"
]
}
],
Expand Down Expand Up @@ -581,16 +581,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635974748 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1733635974850 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733635974950 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635975050 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733635975050 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1733635975050 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1733635975050 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635975150 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635975250 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733635975250 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1733722378722 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1733722378822 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733722378924 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733722379024 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733722379024 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1733722379024 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1733722379024 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722379122 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722379224 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733722379224 | 1\n"
]
}
],
Expand Down Expand Up @@ -633,18 +633,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635975368 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635975368 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733635975368 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733635975368 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635975868 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635975868 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733635975868 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733635975868 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733635975868 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1733635975868 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1733635975868 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1733635975868 | 1\n"
"^YYY4HAB... | 1 | 5 | 6 | 1733722379350 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733722379350 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733722379350 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733722379350 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722379850 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733722379850 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733722379850 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733722379850 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733722379850 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1733722379850 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1733722379850 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1733722379850 | 1\n"
]
}
],
Expand Down Expand Up @@ -688,16 +688,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635976006 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733635976006 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733635976306 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733635976306 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635976406 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733635976406 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733635976508 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733635976508 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733635976508 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1733635976508 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1733722379986 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733722379986 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1733722380288 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1733722380288 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722380388 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733722380388 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1733722380488 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1733722380488 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1733722380488 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1733722380488 | 1\n"
]
}
],
Expand Down

0 comments on commit 450e983

Please sign in to comment.