From c4447fb207cc9bfccd24041acf768e6f0692458f Mon Sep 17 00:00:00 2001 From: Pathway-Dev <72749368+Pathway-Dev@users.noreply.github.com> Date: Thu, 12 Sep 2024 06:40:15 +0200 Subject: [PATCH] Daily Pathway examples refresh Co-authored-by: Manul from Pathway GitOrigin-RevId: a0dce9311d6f2e234d19458605857824062b1706 --- .../tutorials/asynctransformer.ipynb | 110 +++++++++--------- .../notebooks/tutorials/fs_connector.ipynb | 46 ++++---- examples/notebooks/tutorials/indexes.ipynb | 4 +- .../notebooks/tutorials/option-greeks.ipynb | 3 +- 4 files changed, 81 insertions(+), 82 deletions(-) diff --git a/examples/notebooks/tutorials/asynctransformer.ipynb b/examples/notebooks/tutorials/asynctransformer.ipynb index e70ce427..42020516 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 | 1725942849926 | 1\n", - "^3CZ78B4... | 2 | 3 | 1725942850126 | 1\n", - "^YYY4HAB... | 6 | 7 | 1725942850126 | 1\n", - "^3HN31E1... | 6 | 7 | 1725942850526 | 1\n", - "^X1MXHYY... | 12 | 13 | 1725942850526 | 1\n" + "^Z3QWT29... | 2 | 3 | 1726115668154 | 1\n", + "^3CZ78B4... | 2 | 3 | 1726115668356 | 1\n", + "^YYY4HAB... | 6 | 7 | 1726115668356 | 1\n", + "^3HN31E1... | 6 | 7 | 1726115668756 | 1\n", + "^X1MXHYY... | 12 | 13 | 1726115668756 | 1\n" ] } ], @@ -410,12 +410,12 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942854042 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942854142 | -1\n", - "^Z3QWT29... | 2 | 3 | 4 | 1725942854142 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942854342 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942854544 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725942854544 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1726115672102 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1726115672202 | -1\n", + "^Z3QWT29... | 2 | 3 | 4 | 1726115672202 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115672404 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115672604 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1726115672604 | 1\n" ] } ], @@ -537,18 +537,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942854822 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725942854822 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942855122 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725942855122 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1725942855122 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1725942855122 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942855224 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725942855224 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942855322 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725942855322 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725942855322 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1725942855322 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1726115672848 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1726115672848 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1726115673150 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1726115673150 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1726115673150 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1726115673150 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115673248 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1726115673248 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115673350 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1726115673350 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1726115673350 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1726115673350 | 1\n" ] } ], @@ -581,16 +581,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942855458 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1725942855558 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725942855658 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942855758 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725942855758 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1725942855758 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1725942855758 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942855858 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942855958 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725942855958 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1726115673476 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1726115673576 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1726115673676 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1726115673778 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1726115673778 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1726115673778 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1726115673778 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115673876 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115673976 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1726115673976 | 1\n" ] } ], @@ -633,18 +633,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942856078 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942856078 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725942856078 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725942856078 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942856578 | -1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942856578 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725942856578 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725942856578 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725942856578 | 1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1725942856578 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1725942856578 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1725942856578 | 1\n" + "^YYY4HAB... | 1 | 5 | 6 | 1726115674102 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1726115674102 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1726115674102 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1726115674102 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115674604 | -1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1726115674604 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1726115674604 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1726115674604 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1726115674604 | 1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1726115674604 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1726115674604 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1726115674604 | 1\n" ] } ], @@ -688,16 +688,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942856710 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725942856710 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1725942857010 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1725942857010 | -1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942857110 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725942857110 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1725942857210 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1725942857210 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1725942857210 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1725942857210 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1726115674724 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1726115674724 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1726115675024 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1726115675024 | -1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115675124 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1726115675124 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1726115675224 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1726115675224 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1726115675224 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1726115675224 | 1\n" ] } ], diff --git a/examples/notebooks/tutorials/fs_connector.ipynb b/examples/notebooks/tutorials/fs_connector.ipynb index cec5f4ad..80a1a42c 100644 --- a/examples/notebooks/tutorials/fs_connector.ipynb +++ b/examples/notebooks/tutorials/fs_connector.ipynb @@ -144,10 +144,10 @@ "name": "stdout", "output_type": "stream", "text": [ - "{\"data\":\"test1\",\"diff\":1,\"time\":1725942833112}\r\n", - "{\"data\":\"data2\",\"diff\":1,\"time\":1725942833112}\r\n", - "{\"data\":\"data1\",\"diff\":1,\"time\":1725942833112}\r\n", - "{\"data\":\"test2\",\"diff\":1,\"time\":1725942833112}\r\n" + "{\"data\":\"test1\",\"diff\":1,\"time\":1726115651094}\r\n", + "{\"data\":\"data2\",\"diff\":1,\"time\":1726115651094}\r\n", + "{\"data\":\"data1\",\"diff\":1,\"time\":1726115651094}\r\n", + "{\"data\":\"test2\",\"diff\":1,\"time\":1726115651094}\r\n" ] }, { @@ -161,8 +161,8 @@ "name": "stdout", "output_type": "stream", "text": [ - "{\"data\":\"test1\",\"diff\":1,\"time\":1725942833112}\r\n", - "{\"data\":\"data1\",\"diff\":1,\"time\":1725942833112}\r\n" + "{\"data\":\"test1\",\"diff\":1,\"time\":1726115651094}\r\n", + "{\"data\":\"data1\",\"diff\":1,\"time\":1726115651094}\r\n" ] } ], @@ -218,8 +218,8 @@ "output_type": "stream", "text": [ "out3:\r\n", - "{\"data\":\"data2\",\"diff\":1,\"time\":1725942833806}\r\n", - "{\"data\":\"test2\",\"diff\":1,\"time\":1725942833806}\r\n" + "{\"data\":\"data2\",\"diff\":1,\"time\":1726115651792}\r\n", + "{\"data\":\"test2\",\"diff\":1,\"time\":1726115651792}\r\n" ] } ], @@ -333,10 +333,10 @@ "output_type": "stream", "text": [ "header1,header2,time,diff\r\n", - "\"data7\",\"data8\",1725942835374,1\r\n", - "\"data1\",\"data2\",1725942835374,1\r\n", - "\"data3\",\"data4\",1725942835374,1\r\n", - "\"data5\",\"data6\",1725942835374,1\r\n" + "\"data7\",\"data8\",1726115653356,1\r\n", + "\"data1\",\"data2\",1726115653356,1\r\n", + "\"data3\",\"data4\",1726115653356,1\r\n", + "\"data5\",\"data6\",1726115653356,1\r\n" ] } ], @@ -450,9 +450,9 @@ "name": "stdout", "output_type": "stream", "text": [ - "{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1725942836800}\r\n", - "{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1725942836800}\r\n", - "{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1725942836800}\r\n" + "{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1726115654786}\r\n", + "{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1726115654786}\r\n", + "{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1726115654786}\r\n" ] } ], @@ -521,10 +521,10 @@ "output_type": "stream", "text": [ "data,time,diff\r\n", - "\"test1\",1725942837238,1\r\n", - "\"data2\",1725942837238,1\r\n", - "\"data1\",1725942837238,1\r\n", - "\"test2\",1725942837238,1\r\n" + "\"test1\",1726115655190,1\r\n", + "\"data2\",1726115655190,1\r\n", + "\"data1\",1726115655190,1\r\n", + "\"test2\",1726115655190,1\r\n" ] }, { @@ -539,8 +539,8 @@ "output_type": "stream", "text": [ "data,time,diff\r\n", - "\"test2\\ndata2\",1725942837238,1\r\n", - "\"test1\\ndata1\",1725942837238,1\r\n" + "\"test2\\ndata2\",1726115655190,1\r\n", + "\"test1\\ndata1\",1726115655190,1\r\n" ] }, { @@ -555,8 +555,8 @@ "output_type": "stream", "text": [ "data,time,diff\r\n", - "[116, 101, 115, 116, 50, 10, 100, 97, 116, 97, 50, 10],1725942837238,1\r\n", - "[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1725942837238,1\r\n" + "[116, 101, 115, 116, 50, 10, 100, 97, 116, 97, 50, 10],1726115655190,1\r\n", + "[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1726115655190,1\r\n" ] } ], diff --git a/examples/notebooks/tutorials/indexes.ipynb b/examples/notebooks/tutorials/indexes.ipynb index a7249220..eafcfdfb 100644 --- a/examples/notebooks/tutorials/indexes.ipynb +++ b/examples/notebooks/tutorials/indexes.ipynb @@ -835,8 +835,8 @@ "lines_to_next_cell": 0 }, "source": [ - "A similar approach was taken in our [alerting example](/developers/templates/llm-alert-pathway/).\n", - "It is an LLM app that can send you alerts on slack when the response to your query has changed significantly." + "A similar approach was taken in our [alerting example](https://github.com/pathwaycom/llm-app/tree/main/examples/pipelines/drive_alert).\n", + "It is an LLM app that can send you alerts on slack when the response to your query has changed significantly." ] }, { diff --git a/examples/notebooks/tutorials/option-greeks.ipynb b/examples/notebooks/tutorials/option-greeks.ipynb index f632d047..b8603f98 100644 --- a/examples/notebooks/tutorials/option-greeks.ipynb +++ b/examples/notebooks/tutorials/option-greeks.ipynb @@ -685,8 +685,7 @@ "name": "stdout", "output_type": "stream", "text": [ - " | ts_recv | raw_symbol | expiration | instrument_class | strike_price | underlying | instrument_id | option_midprice", - "\n", + " | ts_recv | raw_symbol | expiration | instrument_class | strike_price | underlying | instrument_id | option_midprice\n", "^6ZHYYVZ... | 1712275200000000000 | ESM4 C3950 | 1718976600000000000 | C | 3950.0 | ESM4 | 4162742 | 1255.875\n", "^W64CERT... | 1712275200000000000 | ESM4 C4000 | 1718976600000000000 | C | 4000.0 | ESM4 | 574893 | 1206.25\n", "^WGHCM9D... | 1712275200000000000 | ESM4 C4050 | 1718976600000000000 | C | 4050.0 | ESM4 | 4162333 | 1156.75\n",