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 <github.manul@pathway.com>
GitOrigin-RevId: b47683600c186c63e96b1e02eb8679ece1e59387
  • Loading branch information
@Pathway-Dev
Pathway-Dev and Manul from Pathway committed Sep 1, 2024
1 parent 2db782c commit b564044
Show file tree
Hide file tree
Showing 5 changed files with 83 additions and 89 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 | 1725078766468 | 1\n",
"^3CZ78B4... | 2 | 3 | 1725078766668 | 1\n",
"^YYY4HAB... | 6 | 7 | 1725078766668 | 1\n",
"^3HN31E1... | 6 | 7 | 1725078767070 | 1\n",
"^X1MXHYY... | 12 | 13 | 1725078767070 | 1\n"
"^Z3QWT29... | 2 | 3 | 1725165161292 | 1\n",
"^3CZ78B4... | 2 | 3 | 1725165161492 | 1\n",
"^YYY4HAB... | 6 | 7 | 1725165161492 | 1\n",
"^3HN31E1... | 6 | 7 | 1725165161894 | 1\n",
"^X1MXHYY... | 12 | 13 | 1725165161894 | 1\n"
]
}
],
Expand Down Expand Up @@ -410,12 +410,12 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078770522 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078770622 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1725078770622 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078770822 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078771024 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725078771024 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1725165165316 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725165165418 | -1\n",
"^Z3QWT29... | 2 | 3 | 4 | 1725165165418 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165165618 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165165818 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725165165818 | 1\n"
]
}
],
Expand Down Expand Up @@ -537,18 +537,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078771288 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725078771288 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078771588 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725078771588 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1725078771588 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1725078771588 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078771688 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725078771688 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078771788 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725078771788 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725078771788 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1725078771788 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1725165166060 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725165166060 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725165166362 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725165166362 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1725165166362 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1725165166362 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165166462 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725165166462 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165166560 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725165166560 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725165166560 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1725165166560 | 1\n"
]
}
],
Expand Down Expand Up @@ -581,16 +581,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078771924 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1725078772026 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725078772126 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078772226 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725078772226 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1725078772226 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1725078772226 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078772326 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078772426 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725078772426 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1725165166670 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1725165166770 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725165166870 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725165166970 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725165166970 | -1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1725165166970 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1725165166970 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165167070 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165167170 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725165167170 | 1\n"
]
}
],
Expand Down Expand Up @@ -633,18 +633,18 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078772570 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078772570 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725078772570 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725078772570 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078773070 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078773070 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725078773070 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725078773070 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725078773070 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1725078773070 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1725078773070 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1725078773070 | 1\n"
"^YYY4HAB... | 1 | 5 | 6 | 1725165167320 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725165167320 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725165167320 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725165167320 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165167820 | -1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725165167820 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725165167820 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725165167820 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725165167820 | 1\n",
"^Z3QWT29... | 2 | 4 | 5 | 1725165167820 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1725165167820 | 1\n",
"^3HN31E1... | 4 | 2 | 3 | 1725165167820 | 1\n"
]
}
],
Expand Down Expand Up @@ -688,16 +688,16 @@
"output_type": "stream",
"text": [
" | group | value | ret | __time__ | __diff__\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078773206 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725078773206 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725078773508 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725078773508 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078773608 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725078773608 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725078773708 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725078773708 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725078773708 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1725078773708 | 1\n"
"^Z3QWT29... | 2 | 1 | 2 | 1725165167966 | 1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725165167966 | 1\n",
"^Z3QWT29... | 2 | 1 | 2 | 1725165168266 | -1\n",
"^3HN31E1... | 4 | 3 | 4 | 1725165168266 | -1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165168366 | 1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725165168366 | 1\n",
"^YYY4HAB... | 1 | 5 | 6 | 1725165168466 | -1\n",
"^3CZ78B4... | 3 | 1 | 2 | 1725165168466 | -1\n",
"^YYY4HAB... | 1 | 2 | 3 | 1725165168466 | 1\n",
"^3CZ78B4... | 3 | 2 | 3 | 1725165168466 | 1\n"
]
}
],
Expand Down
4 changes: 2 additions & 2 deletions examples/notebooks/tutorials/consistency.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -453,14 +453,14 @@
"name": "stderr",
"output_type": "stream",
"text": [
"WARNING:pathway_engine.connectors.monitoring:PythonReader-0: Closing the data source\n"
"INFO:root:Removing account 1 balance: 158\n"
]
},
{
"name": "stderr",
"output_type": "stream",
"text": [
"INFO:root:Removing account 1 balance: 158\n"
"WARNING:pathway_engine.connectors.monitoring:PythonReader-0: Closing the data source\n"
]
},
{
Expand Down
46 changes: 23 additions & 23 deletions examples/notebooks/tutorials/fs_connector.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -144,10 +144,10 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"data\":\"test1\",\"diff\":1,\"time\":1725078749292}\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1725078749292}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1725078749292}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1725078749292}\r\n"
"{\"data\":\"test1\",\"diff\":1,\"time\":1725165144204}\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1725165144204}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1725165144204}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1725165144204}\r\n"
]
},
{
Expand All @@ -161,8 +161,8 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"data\":\"test1\",\"diff\":1,\"time\":1725078749292}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1725078749292}\r\n"
"{\"data\":\"test1\",\"diff\":1,\"time\":1725165144204}\r\n",
"{\"data\":\"data1\",\"diff\":1,\"time\":1725165144204}\r\n"
]
}
],
Expand Down Expand Up @@ -218,8 +218,8 @@
"output_type": "stream",
"text": [
"out3:\r\n",
"{\"data\":\"data2\",\"diff\":1,\"time\":1725078749984}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1725078749984}\r\n"
"{\"data\":\"data2\",\"diff\":1,\"time\":1725165144922}\r\n",
"{\"data\":\"test2\",\"diff\":1,\"time\":1725165144922}\r\n"
]
}
],
Expand Down Expand Up @@ -333,10 +333,10 @@
"output_type": "stream",
"text": [
"header1,header2,time,diff\r\n",
"\"data7\",\"data8\",1725078751570,1\r\n",
"\"data1\",\"data2\",1725078751570,1\r\n",
"\"data3\",\"data4\",1725078751570,1\r\n",
"\"data5\",\"data6\",1725078751570,1\r\n"
"\"data7\",\"data8\",1725165146492,1\r\n",
"\"data1\",\"data2\",1725165146492,1\r\n",
"\"data3\",\"data4\",1725165146492,1\r\n",
"\"data5\",\"data6\",1725165146492,1\r\n"
]
}
],
Expand Down Expand Up @@ -450,9 +450,9 @@
"name": "stdout",
"output_type": "stream",
"text": [
"{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1725078753008}\r\n",
"{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1725078753010}\r\n",
"{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1725078753010}\r\n"
"{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1725165147918}\r\n",
"{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1725165147918}\r\n",
"{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1725165147918}\r\n"
]
}
],
Expand Down Expand Up @@ -521,10 +521,10 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"\"test1\",1725078753434,1\r\n",
"\"data2\",1725078753434,1\r\n",
"\"data1\",1725078753434,1\r\n",
"\"test2\",1725078753434,1\r\n"
"\"test1\",1725165148336,1\r\n",
"\"data2\",1725165148336,1\r\n",
"\"data1\",1725165148336,1\r\n",
"\"test2\",1725165148336,1\r\n"
]
},
{
Expand All @@ -539,8 +539,8 @@
"output_type": "stream",
"text": [
"data,time,diff\r\n",
"\"test2\\ndata2\",1725078753434,1\r\n",
"\"test1\\ndata1\",1725078753434,1\r\n"
"\"test2\\ndata2\",1725165148336,1\r\n",
"\"test1\\ndata1\",1725165148336,1\r\n"
]
},
{
Expand All @@ -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],1725078753434,1\r\n",
"[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1725078753434,1\r\n"
"[116, 101, 115, 116, 50, 10, 100, 97, 116, 97, 50, 10],1725165148336,1\r\n",
"[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1725165148336,1\r\n"
]
}
],
Expand Down
3 changes: 2 additions & 1 deletion examples/notebooks/tutorials/json_type.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -332,7 +332,8 @@
"name": "stdout",
"output_type": "stream",
"text": [
" | title | metadata\n",
" | title | metadata",
"\n",
"^Z3QVC46... | \"Hamlet\" | {\"category\": \"Tragedy\", \"century\": 17, \"title\": \"Hamlet\", \"year\": 1603}\n",
"^X1MQZF8... | \"Kafka on the Shore\" | {\"category\": \"Literary Fiction\", \"century\": 21, \"title\": \"Kafka on the Shore\", \"year\": 2002}\n",
"^Z3QHRW2... | \"Macbeth\" | {\"category\": \"Tragedy\", \"century\": 17, \"title\": \"Macbeth\", \"year\": 1623}\n",
Expand Down
9 changes: 1 addition & 8 deletions examples/notebooks/tutorials/udf.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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"
]
},
{
Expand Down

0 comments on commit b564044

Please sign in to comment.