From e60af02f027f42b801a7592ce9371a0fc9218276 Mon Sep 17 00:00:00 2001 From: Pathway-Dev <72749368+Pathway-Dev@users.noreply.github.com> Date: Fri, 24 Jan 2025 06:39:09 +0100 Subject: [PATCH] Daily Pathway examples refresh Co-authored-by: Manul from Pathway GitOrigin-RevId: 528815cce40056165d8089605b255d4f96dd0ece --- .../tutorials/asynctransformer.ipynb | 110 +++++++++--------- .../notebooks/tutorials/basic_datatypes.ipynb | 3 +- 2 files changed, 56 insertions(+), 57 deletions(-) diff --git a/examples/notebooks/tutorials/asynctransformer.ipynb b/examples/notebooks/tutorials/asynctransformer.ipynb index eea2d129..2c0901e5 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 | 1737610491972 | 1\n", - "^3CZ78B4... | 2 | 3 | 1737610492172 | 1\n", - "^YYY4HAB... | 6 | 7 | 1737610492172 | 1\n", - "^3HN31E1... | 6 | 7 | 1737610492574 | 1\n", - "^X1MXHYY... | 12 | 13 | 1737610492574 | 1\n" + "^Z3QWT29... | 2 | 3 | 1737696801842 | 1\n", + "^3CZ78B4... | 2 | 3 | 1737696802042 | 1\n", + "^YYY4HAB... | 6 | 7 | 1737696802042 | 1\n", + "^3HN31E1... | 6 | 7 | 1737696802444 | 1\n", + "^X1MXHYY... | 12 | 13 | 1737696802444 | 1\n" ] } ], @@ -410,12 +410,12 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610495988 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610496088 | -1\n", - "^Z3QWT29... | 2 | 3 | 4 | 1737610496088 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610496288 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610496488 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1737610496488 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1737696805882 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1737696805982 | -1\n", + "^Z3QWT29... | 2 | 3 | 4 | 1737696805982 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696806182 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696806382 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1737696806382 | 1\n" ] } ], @@ -537,18 +537,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610496726 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1737610496726 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610497028 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1737610497028 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1737610497028 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1737610497028 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610497128 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1737610497128 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610497228 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1737610497228 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1737610497228 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1737610497228 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1737696806632 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1737696806632 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1737696806932 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1737696806932 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1737696806932 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1737696806932 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696807032 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1737696807032 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696807132 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1737696807132 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1737696807132 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1737696807132 | 1\n" ] } ], @@ -581,16 +581,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610497350 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1737610497450 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1737610497550 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610497650 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1737610497650 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1737610497650 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1737610497650 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610497750 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610497850 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1737610497850 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1737696807302 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1737696807402 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1737696807502 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1737696807602 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1737696807602 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1737696807602 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1737696807602 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696807702 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696807802 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1737696807802 | 1\n" ] } ], @@ -633,18 +633,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610497994 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610497994 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1737610497994 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1737610497994 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610498494 | -1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610498494 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1737610498494 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1737610498494 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1737610498494 | 1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1737610498494 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1737610498494 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1737610498494 | 1\n" + "^YYY4HAB... | 1 | 5 | 6 | 1737696807938 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1737696807938 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1737696807938 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1737696807938 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696808438 | -1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1737696808438 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1737696808438 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1737696808438 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1737696808438 | 1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1737696808438 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1737696808438 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1737696808438 | 1\n" ] } ], @@ -688,16 +688,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610498626 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1737610498626 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1737610498926 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1737610498926 | -1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610499026 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1737610499026 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1737610499126 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1737610499126 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1737610499126 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1737610499126 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1737696808596 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1737696808596 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1737696808898 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1737696808898 | -1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696808998 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1737696808998 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1737696809098 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1737696809098 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1737696809098 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1737696809098 | 1\n" ] } ], diff --git a/examples/notebooks/tutorials/basic_datatypes.ipynb b/examples/notebooks/tutorials/basic_datatypes.ipynb index 9327e8f5..164fe37b 100644 --- a/examples/notebooks/tutorials/basic_datatypes.ipynb +++ b/examples/notebooks/tutorials/basic_datatypes.ipynb @@ -1171,8 +1171,7 @@ "output_type": "stream", "text": [ "id | timestamp | values | values_str | date | diff_date\n", - "ANY_POINTER | INT | INT | STR | DATE_TIME_NAIVE | Optional(DURATION)", - "\n" + "ANY_POINTER | INT | INT | STR | DATE_TIME_NAIVE | Optional(DURATION)\n" ] } ],