From a6059fd87b5a2cd5c2987bba9cb2f7d8705a5825 Mon Sep 17 00:00:00 2001 From: Pathway-Dev <72749368+Pathway-Dev@users.noreply.github.com> Date: Fri, 29 Nov 2024 06:41:22 +0100 Subject: [PATCH] Daily Pathway examples refresh Co-authored-by: Manul from Pathway GitOrigin-RevId: ce37f452afee03e56b7d67c1697fe93f7fb0e8fb --- .../tutorials/asynctransformer.ipynb | 110 +++++++++--------- examples/notebooks/tutorials/udf.ipynb | 9 +- 2 files changed, 56 insertions(+), 63 deletions(-) diff --git a/examples/notebooks/tutorials/asynctransformer.ipynb b/examples/notebooks/tutorials/asynctransformer.ipynb index e639fa08..4e1718fd 100644 --- a/examples/notebooks/tutorials/asynctransformer.ipynb +++ b/examples/notebooks/tutorials/asynctransformer.ipynb @@ -162,11 +162,11 @@ "output_type": "stream", "text": [ " | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 3 | 1732772080278 | 1\n", - "^3CZ78B4... | 2 | 3 | 1732772080478 | 1\n", - "^YYY4HAB... | 6 | 7 | 1732772080478 | 1\n", - "^3HN31E1... | 6 | 7 | 1732772080878 | 1\n", - "^X1MXHYY... | 12 | 13 | 1732772080878 | 1\n" + "^Z3QWT29... | 2 | 3 | 1732858403174 | 1\n", + "^3CZ78B4... | 2 | 3 | 1732858403374 | 1\n", + "^YYY4HAB... | 6 | 7 | 1732858403374 | 1\n", + "^3HN31E1... | 6 | 7 | 1732858403776 | 1\n", + "^X1MXHYY... | 12 | 13 | 1732858403776 | 1\n" ] } ], @@ -410,12 +410,12 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772084220 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772084320 | -1\n", - "^Z3QWT29... | 2 | 3 | 4 | 1732772084320 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772084522 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772084722 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1732772084722 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1732858407124 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1732858407226 | -1\n", + "^Z3QWT29... | 2 | 3 | 4 | 1732858407226 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858407426 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858407626 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1732858407626 | 1\n" ] } ], @@ -537,18 +537,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772084972 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1732772084972 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772085274 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1732772085274 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1732772085274 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1732772085274 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772085374 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1732772085374 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772085474 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1732772085474 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1732772085474 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1732772085474 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1732858407866 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1732858407866 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1732858408168 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1732858408168 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1732858408168 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1732858408168 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858408268 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1732858408268 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858408368 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1732858408368 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1732858408368 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1732858408368 | 1\n" ] } ], @@ -581,16 +581,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772085588 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1732772085688 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1732772085788 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772085888 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1732772085888 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1732772085888 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1732772085888 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772085988 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772086088 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1732772086088 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1732858408490 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1732858408590 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1732858408690 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1732858408790 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1732858408790 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1732858408790 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1732858408790 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858408890 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858408990 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1732858408990 | 1\n" ] } ], @@ -633,18 +633,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772086214 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772086214 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1732772086214 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1732772086214 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772086716 | -1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772086716 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1732772086716 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1732772086716 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1732772086716 | 1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1732772086716 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1732772086716 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1732772086716 | 1\n" + "^YYY4HAB... | 1 | 5 | 6 | 1732858409128 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1732858409128 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1732858409128 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1732858409128 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858409628 | -1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1732858409628 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1732858409628 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1732858409628 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1732858409628 | 1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1732858409628 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1732858409628 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1732858409628 | 1\n" ] } ], @@ -688,16 +688,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772086834 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1732772086834 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1732772087134 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1732772087134 | -1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772087236 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1732772087236 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1732772087334 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1732772087334 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1732772087334 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1732772087334 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1732858409748 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1732858409748 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1732858410048 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1732858410048 | -1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858410148 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1732858410148 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1732858410248 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1732858410248 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1732858410248 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1732858410248 | 1\n" ] } ], diff --git a/examples/notebooks/tutorials/udf.ipynb b/examples/notebooks/tutorials/udf.ipynb index 9fbfd923..e37c2734 100644 --- a/examples/notebooks/tutorials/udf.ipynb +++ b/examples/notebooks/tutorials/udf.ipynb @@ -900,14 +900,7 @@ "name": "stdout", "output_type": "stream", "text": [ - "inc_async(0.2) finishing" - ] - }, - { - "name": "stdout", - "output_type": "stream", - "text": [ - "\n" + "inc_async(0.2) finishing\n" ] }, {