From d82daf21303326b72ba0799210f2179a156442e2 Mon Sep 17 00:00:00 2001 From: Pathway-Dev <72749368+Pathway-Dev@users.noreply.github.com> Date: Mon, 13 Jan 2025 06:39:11 +0100 Subject: [PATCH] Daily Pathway examples refresh Co-authored-by: Manul from Pathway GitOrigin-RevId: 9f8d80a9633514d478b0e0f16ea594165c512d90 --- .../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 fa434fc4..9c28ac20 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 | 1736659967054 | 1\n", - "^3CZ78B4... | 2 | 3 | 1736659967254 | 1\n", - "^YYY4HAB... | 6 | 7 | 1736659967254 | 1\n", - "^3HN31E1... | 6 | 7 | 1736659967656 | 1\n", - "^X1MXHYY... | 12 | 13 | 1736659967656 | 1\n" + "^Z3QWT29... | 2 | 3 | 1736746377326 | 1\n", + "^3CZ78B4... | 2 | 3 | 1736746377526 | 1\n", + "^YYY4HAB... | 6 | 7 | 1736746377526 | 1\n", + "^3HN31E1... | 6 | 7 | 1736746377928 | 1\n", + "^X1MXHYY... | 12 | 13 | 1736746377928 | 1\n" ] } ], @@ -410,12 +410,12 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659971044 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659971146 | -1\n", - "^Z3QWT29... | 2 | 3 | 4 | 1736659971146 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659971346 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659971546 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1736659971546 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1736746381330 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1736746381430 | -1\n", + "^Z3QWT29... | 2 | 3 | 4 | 1736746381430 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746381630 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746381832 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1736746381832 | 1\n" ] } ], @@ -537,18 +537,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659971796 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1736659971796 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659972098 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1736659972098 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1736659972098 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1736659972098 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659972196 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1736659972196 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659972296 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1736659972296 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1736659972296 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1736659972296 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1736746382070 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1736746382070 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1736746382370 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1736746382370 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1736746382370 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1736746382370 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746382470 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1736746382470 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746382570 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1736746382570 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1736746382570 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1736746382570 | 1\n" ] } ], @@ -581,16 +581,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659972406 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1736659972506 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1736659972608 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659972708 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1736659972708 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1736659972708 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1736659972708 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659972806 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659972906 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1736659972906 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1736746382706 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1736746382806 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1736746382908 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1736746383008 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1736746383008 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1736746383008 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1736746383008 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746383108 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746383208 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1736746383208 | 1\n" ] } ], @@ -633,18 +633,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659973036 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659973036 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1736659973036 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1736659973036 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659973538 | -1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659973538 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1736659973538 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1736659973538 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1736659973538 | 1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1736659973538 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1736659973538 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1736659973538 | 1\n" + "^YYY4HAB... | 1 | 5 | 6 | 1736746383344 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1736746383344 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1736746383344 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1736746383344 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746383846 | -1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1736746383846 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1736746383846 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1736746383846 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1736746383846 | 1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1736746383846 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1736746383846 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1736746383846 | 1\n" ] } ], @@ -688,16 +688,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659973670 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1736659973670 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1736659973972 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1736659973972 | -1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659974072 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1736659974072 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1736659974172 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1736659974172 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1736659974172 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1736659974172 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1736746383982 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1736746383982 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1736746384282 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1736746384282 | -1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746384382 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1736746384382 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1736746384482 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1736746384482 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1736746384482 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1736746384482 | 1\n" ] } ], diff --git a/examples/notebooks/tutorials/udf.ipynb b/examples/notebooks/tutorials/udf.ipynb index 3cf2a939..4ad259a7 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" ] }, {