Daily Pathway examples refresh

Co-authored-by: Manul from Pathway <github.manul@pathway.com> GitOrigin-RevId: 6068f2d1113b63d659d5efcfcfd7ddba6cb5fdb1
pathwaycom · Sep 4, 2024 · 5f09967 · 5f09967
1 parent 015dc2f
commit 5f09967
Show file tree

Hide file tree

Showing 2 changed files with 78 additions and 78 deletions.
diff --git 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 | 1725337968054 | 1\n",
- "^3CZ78B4... | 2 | 3 | 1725337968254 | 1\n",
- "^YYY4HAB... | 6 | 7 | 1725337968254 | 1\n",
- "^3HN31E1... | 6 | 7 | 1725337968656 | 1\n",
- "^X1MXHYY... | 12 | 13 | 1725337968656 | 1\n"
+ "^Z3QWT29... | 2 | 3 | 1725424375496 | 1\n",
+ "^3CZ78B4... | 2 | 3 | 1725424375698 | 1\n",
+ "^YYY4HAB... | 6 | 7 | 1725424375698 | 1\n",
+ "^3HN31E1... | 6 | 7 | 1725424376098 | 1\n",
+ "^X1MXHYY... | 12 | 13 | 1725424376098 | 1\n"
  ]
  }
  ],
@@ -410,12 +410,12 @@
  "output_type": "stream",
  "text": [
  " | group | value | ret | __time__ | __diff__\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337972330 | 1\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337972430 | -1\n",
- "^Z3QWT29... | 2 | 3 | 4 | 1725337972430 | 1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337972632 | 1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337972830 | -1\n",
- "^YYY4HAB... | 1 | 2 | 3 | 1725337972830 | 1\n"
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424379536 | 1\n",
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424379636 | -1\n",
+ "^Z3QWT29... | 2 | 3 | 4 | 1725424379636 | 1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424379836 | 1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424380036 | -1\n",
+ "^YYY4HAB... | 1 | 2 | 3 | 1725424380036 | 1\n"
  ]
  }
  ],
@@ -537,18 +537,18 @@
  "output_type": "stream",
  "text": [
  " | group | value | ret | __time__ | __diff__\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337973240 | 1\n",
- "^3HN31E1... | 4 | 3 | 4 | 1725337973240 | 1\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337973542 | -1\n",
- "^3HN31E1... | 4 | 3 | 4 | 1725337973542 | -1\n",
- "^Z3QWT29... | 2 | 4 | 5 | 1725337973542 | 1\n",
- "^3HN31E1... | 4 | 2 | 3 | 1725337973542 | 1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337973640 | 1\n",
- "^3CZ78B4... | 3 | 1 | 2 | 1725337973640 | 1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337973742 | -1\n",
- "^3CZ78B4... | 3 | 1 | 2 | 1725337973742 | -1\n",
- "^YYY4HAB... | 1 | 2 | 3 | 1725337973742 | 1\n",
- "^3CZ78B4... | 3 | 2 | 3 | 1725337973742 | 1\n"
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424380280 | 1\n",
+ "^3HN31E1... | 4 | 3 | 4 | 1725424380280 | 1\n",
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424380580 | -1\n",
+ "^3HN31E1... | 4 | 3 | 4 | 1725424380580 | -1\n",
+ "^Z3QWT29... | 2 | 4 | 5 | 1725424380580 | 1\n",
+ "^3HN31E1... | 4 | 2 | 3 | 1725424380580 | 1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424380680 | 1\n",
+ "^3CZ78B4... | 3 | 1 | 2 | 1725424380680 | 1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424380780 | -1\n",
+ "^3CZ78B4... | 3 | 1 | 2 | 1725424380780 | -1\n",
+ "^YYY4HAB... | 1 | 2 | 3 | 1725424380780 | 1\n",
+ "^3CZ78B4... | 3 | 2 | 3 | 1725424380780 | 1\n"
  ]
  }
  ],
@@ -581,16 +581,16 @@
  "output_type": "stream",
  "text": [
  " | group | value | ret | __time__ | __diff__\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337973870 | 1\n",
- "^3CZ78B4... | 3 | 2 | 3 | 1725337973970 | 1\n",
- "^3HN31E1... | 4 | 3 | 4 | 1725337974072 | 1\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337974172 | -1\n",
- "^3HN31E1... | 4 | 3 | 4 | 1725337974172 | -1\n",
- "^Z3QWT29... | 2 | 4 | 5 | 1725337974172 | 1\n",
- "^3HN31E1... | 4 | 2 | 3 | 1725337974172 | 1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337974270 | 1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337974372 | -1\n",
- "^YYY4HAB... | 1 | 2 | 3 | 1725337974372 | 1\n"
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424380932 | 1\n",
+ "^3CZ78B4... | 3 | 2 | 3 | 1725424381032 | 1\n",
+ "^3HN31E1... | 4 | 3 | 4 | 1725424381134 | 1\n",
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424381234 | -1\n",
+ "^3HN31E1... | 4 | 3 | 4 | 1725424381234 | -1\n",
+ "^Z3QWT29... | 2 | 4 | 5 | 1725424381234 | 1\n",
+ "^3HN31E1... | 4 | 2 | 3 | 1725424381234 | 1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424381334 | 1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424381434 | -1\n",
+ "^YYY4HAB... | 1 | 2 | 3 | 1725424381434 | 1\n"
  ]
  }
  ],
@@ -633,18 +633,18 @@
  "output_type": "stream",
  "text": [
  " | group | value | ret | __time__ | __diff__\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337974498 | 1\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337974498 | 1\n",
- "^3CZ78B4... | 3 | 1 | 2 | 1725337974498 | 1\n",
- "^3HN31E1... | 4 | 3 | 4 | 1725337974498 | 1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337975000 | -1\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337975000 | -1\n",
- "^3CZ78B4... | 3 | 1 | 2 | 1725337975000 | -1\n",
- "^3HN31E1... | 4 | 3 | 4 | 1725337975000 | -1\n",
- "^YYY4HAB... | 1 | 2 | 3 | 1725337975000 | 1\n",
- "^Z3QWT29... | 2 | 4 | 5 | 1725337975000 | 1\n",
- "^3CZ78B4... | 3 | 2 | 3 | 1725337975000 | 1\n",
- "^3HN31E1... | 4 | 2 | 3 | 1725337975000 | 1\n"
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424381570 | 1\n",
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424381570 | 1\n",
+ "^3CZ78B4... | 3 | 1 | 2 | 1725424381570 | 1\n",
+ "^3HN31E1... | 4 | 3 | 4 | 1725424381570 | 1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424382070 | -1\n",
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424382070 | -1\n",
+ "^3CZ78B4... | 3 | 1 | 2 | 1725424382070 | -1\n",
+ "^3HN31E1... | 4 | 3 | 4 | 1725424382070 | -1\n",
+ "^YYY4HAB... | 1 | 2 | 3 | 1725424382070 | 1\n",
+ "^Z3QWT29... | 2 | 4 | 5 | 1725424382070 | 1\n",
+ "^3CZ78B4... | 3 | 2 | 3 | 1725424382070 | 1\n",
+ "^3HN31E1... | 4 | 2 | 3 | 1725424382070 | 1\n"
  ]
  }
  ],
@@ -688,16 +688,16 @@
  "output_type": "stream",
  "text": [
  " | group | value | ret | __time__ | __diff__\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337975130 | 1\n",
- "^3HN31E1... | 4 | 3 | 4 | 1725337975130 | 1\n",
- "^Z3QWT29... | 2 | 1 | 2 | 1725337975430 | -1\n",
- "^3HN31E1... | 4 | 3 | 4 | 1725337975430 | -1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337975530 | 1\n",
- "^3CZ78B4... | 3 | 1 | 2 | 1725337975530 | 1\n",
- "^YYY4HAB... | 1 | 5 | 6 | 1725337975630 | -1\n",
- "^3CZ78B4... | 3 | 1 | 2 | 1725337975630 | -1\n",
- "^YYY4HAB... | 1 | 2 | 3 | 1725337975630 | 1\n",
- "^3CZ78B4... | 3 | 2 | 3 | 1725337975630 | 1\n"
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424382214 | 1\n",
+ "^3HN31E1... | 4 | 3 | 4 | 1725424382214 | 1\n",
+ "^Z3QWT29... | 2 | 1 | 2 | 1725424382514 | -1\n",
+ "^3HN31E1... | 4 | 3 | 4 | 1725424382514 | -1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424382616 | 1\n",
+ "^3CZ78B4... | 3 | 1 | 2 | 1725424382616 | 1\n",
+ "^YYY4HAB... | 1 | 5 | 6 | 1725424382714 | -1\n",
+ "^3CZ78B4... | 3 | 1 | 2 | 1725424382714 | -1\n",
+ "^YYY4HAB... | 1 | 2 | 3 | 1725424382714 | 1\n",
+ "^3CZ78B4... | 3 | 2 | 3 | 1725424382714 | 1\n"
  ]
  }
  ],

diff --git 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\":1725337951126}\r\n",
- "{\"data\":\"data2\",\"diff\":1,\"time\":1725337951126}\r\n",
- "{\"data\":\"data1\",\"diff\":1,\"time\":1725337951126}\r\n",
- "{\"data\":\"test2\",\"diff\":1,\"time\":1725337951126}\r\n"
+ "{\"data\":\"test1\",\"diff\":1,\"time\":1725424358618}\r\n",
+ "{\"data\":\"data2\",\"diff\":1,\"time\":1725424358618}\r\n",
+ "{\"data\":\"data1\",\"diff\":1,\"time\":1725424358618}\r\n",
+ "{\"data\":\"test2\",\"diff\":1,\"time\":1725424358618}\r\n"
  ]
  },
  {
@@ -161,8 +161,8 @@
  "name": "stdout",
  "output_type": "stream",
  "text": [
- "{\"data\":\"test1\",\"diff\":1,\"time\":1725337951126}\r\n",
- "{\"data\":\"data1\",\"diff\":1,\"time\":1725337951126}\r\n"
+ "{\"data\":\"test1\",\"diff\":1,\"time\":1725424358618}\r\n",
+ "{\"data\":\"data1\",\"diff\":1,\"time\":1725424358618}\r\n"
  ]
  }
  ],
@@ -218,8 +218,8 @@
  "output_type": "stream",
  "text": [
  "out3:\r\n",
- "{\"data\":\"data2\",\"diff\":1,\"time\":1725337951836}\r\n",
- "{\"data\":\"test2\",\"diff\":1,\"time\":1725337951836}\r\n"
+ "{\"data\":\"data2\",\"diff\":1,\"time\":1725424359306}\r\n",
+ "{\"data\":\"test2\",\"diff\":1,\"time\":1725424359306}\r\n"
  ]
  }
  ],
@@ -333,10 +333,10 @@
  "output_type": "stream",
  "text": [
  "header1,header2,time,diff\r\n",
- "\"data7\",\"data8\",1725337953440,1\r\n",
- "\"data1\",\"data2\",1725337953440,1\r\n",
- "\"data3\",\"data4\",1725337953440,1\r\n",
- "\"data5\",\"data6\",1725337953440,1\r\n"
+ "\"data7\",\"data8\",1725424360896,1\r\n",
+ "\"data1\",\"data2\",1725424360896,1\r\n",
+ "\"data3\",\"data4\",1725424360896,1\r\n",
+ "\"data5\",\"data6\",1725424360896,1\r\n"
  ]
  }
  ],
@@ -450,9 +450,9 @@
  "name": "stdout",
  "output_type": "stream",
  "text": [
- "{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1725337954896}\r\n",
- "{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1725337954896}\r\n",
- "{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1725337954896}\r\n"
+ "{\"header1\":\"data7\",\"header2\":\"data8\",\"diff\":1,\"time\":1725424362338}\r\n",
+ "{\"header1\":\"data3\",\"header2\":\"data4\",\"diff\":1,\"time\":1725424362338}\r\n",
+ "{\"header1\":\"data5\",\"header2\":\"data6\",\"diff\":1,\"time\":1725424362338}\r\n"
  ]
  }
  ],
@@ -521,10 +521,10 @@
  "output_type": "stream",
  "text": [
  "data,time,diff\r\n",
- "\"test1\",1725337955304,1\r\n",
- "\"data2\",1725337955304,1\r\n",
- "\"data1\",1725337955304,1\r\n",
- "\"test2\",1725337955304,1\r\n"
+ "\"test1\",1725424362778,1\r\n",
+ "\"data2\",1725424362778,1\r\n",
+ "\"data1\",1725424362778,1\r\n",
+ "\"test2\",1725424362778,1\r\n"
  ]
  },
  {
@@ -539,8 +539,8 @@
  "output_type": "stream",
  "text": [
  "data,time,diff\r\n",
- "\"test2\\ndata2\",1725337955304,1\r\n",
- "\"test1\\ndata1\",1725337955304,1\r\n"
+ "\"test2\\ndata2\",1725424362778,1\r\n",
+ "\"test1\\ndata1\",1725424362778,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],1725337955304,1\r\n",
- "[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1725337955304,1\r\n"
+ "[116, 101, 115, 116, 50, 10, 100, 97, 116, 97, 50, 10],1725424362778,1\r\n",
+ "[116, 101, 115, 116, 49, 10, 100, 97, 116, 97, 49, 10],1725424362778,1\r\n"
  ]
  }
  ],