diff --git a/examples/notebooks/tutorials/asynctransformer.ipynb b/examples/notebooks/tutorials/asynctransformer.ipynb index 952eccbf..cc20c958 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 | 1738128906118 | 1\n", - "^3CZ78B4... | 2 | 3 | 1738128906318 | 1\n", - "^YYY4HAB... | 6 | 7 | 1738128906318 | 1\n", - "^3HN31E1... | 6 | 7 | 1738128906718 | 1\n", - "^X1MXHYY... | 12 | 13 | 1738128906718 | 1\n" + "^Z3QWT29... | 2 | 3 | 1738215341416 | 1\n", + "^3CZ78B4... | 2 | 3 | 1738215341618 | 1\n", + "^YYY4HAB... | 6 | 7 | 1738215341618 | 1\n", + "^3HN31E1... | 6 | 7 | 1738215342016 | 1\n", + "^X1MXHYY... | 12 | 13 | 1738215342018 | 1\n" ] } ], @@ -410,12 +410,12 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128915858 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128915958 | -1\n", - "^Z3QWT29... | 2 | 3 | 4 | 1738128915958 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128916158 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128916358 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738128916358 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1738215351332 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738215351432 | -1\n", + "^Z3QWT29... | 2 | 3 | 4 | 1738215351432 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215351632 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215351832 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738215351832 | 1\n" ] } ], @@ -537,18 +537,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128918266 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738128918266 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128918568 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738128918568 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1738128918568 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1738128918568 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128918668 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738128918668 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128918768 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738128918768 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738128918768 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1738128918768 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1738215353752 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738215353752 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738215354054 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738215354054 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1738215354054 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1738215354054 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215354154 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738215354154 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215354254 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738215354254 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738215354254 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1738215354254 | 1\n" ] } ], @@ -581,16 +581,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128919792 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1738128919892 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738128919992 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128920092 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738128920092 | -1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1738128920092 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1738128920092 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128920192 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128920292 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738128920292 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1738215355218 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1738215355318 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738215355420 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738215355520 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738215355520 | -1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1738215355520 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1738215355520 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215355620 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215355720 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738215355720 | 1\n" ] } ], @@ -633,18 +633,18 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128921302 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128921302 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738128921302 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738128921302 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128921804 | -1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128921804 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738128921804 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738128921804 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738128921804 | 1\n", - "^Z3QWT29... | 2 | 4 | 5 | 1738128921804 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1738128921804 | 1\n", - "^3HN31E1... | 4 | 2 | 3 | 1738128921804 | 1\n" + "^YYY4HAB... | 1 | 5 | 6 | 1738215356686 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738215356686 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738215356686 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738215356686 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215357188 | -1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738215357188 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738215357188 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738215357188 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738215357188 | 1\n", + "^Z3QWT29... | 2 | 4 | 5 | 1738215357188 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1738215357188 | 1\n", + "^3HN31E1... | 4 | 2 | 3 | 1738215357188 | 1\n" ] } ], @@ -688,16 +688,16 @@ "output_type": "stream", "text": [ " | group | value | ret | __time__ | __diff__\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128922752 | 1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738128922752 | 1\n", - "^Z3QWT29... | 2 | 1 | 2 | 1738128923054 | -1\n", - "^3HN31E1... | 4 | 3 | 4 | 1738128923054 | -1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128923152 | 1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738128923152 | 1\n", - "^YYY4HAB... | 1 | 5 | 6 | 1738128923254 | -1\n", - "^3CZ78B4... | 3 | 1 | 2 | 1738128923254 | -1\n", - "^YYY4HAB... | 1 | 2 | 3 | 1738128923254 | 1\n", - "^3CZ78B4... | 3 | 2 | 3 | 1738128923254 | 1\n" + "^Z3QWT29... | 2 | 1 | 2 | 1738215358160 | 1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738215358160 | 1\n", + "^Z3QWT29... | 2 | 1 | 2 | 1738215358460 | -1\n", + "^3HN31E1... | 4 | 3 | 4 | 1738215358460 | -1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215358560 | 1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738215358560 | 1\n", + "^YYY4HAB... | 1 | 5 | 6 | 1738215358660 | -1\n", + "^3CZ78B4... | 3 | 1 | 2 | 1738215358660 | -1\n", + "^YYY4HAB... | 1 | 2 | 3 | 1738215358660 | 1\n", + "^3CZ78B4... | 3 | 2 | 3 | 1738215358660 | 1\n" ] } ], diff --git a/examples/notebooks/tutorials/consistency.ipynb b/examples/notebooks/tutorials/consistency.ipynb index 67aa7eae..73c8d144 100644 --- a/examples/notebooks/tutorials/consistency.ipynb +++ b/examples/notebooks/tutorials/consistency.ipynb @@ -320,7 +320,14 @@ "name": "stderr", "output_type": "stream", "text": [ - "INFO:pathway_engine.connectors.monitoring:PythonReader-0: 0 entries (1 minibatch(es)) have been sent to the engine\n" + "INFO:pathway_engine.connectors.monitoring:PythonReader: 0 entries (1 minibatch(es)) have been sent to the engine\n" + ] + }, + { + "name": "stderr", + "output_type": "stream", + "text": [ + "INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 0 entries, time 1738215575796. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n" ] }, { @@ -446,14 +453,14 @@ "name": "stderr", "output_type": "stream", "text": [ - "INFO:pathway_engine.connectors.monitoring:PythonReader-0: 10 entries (3 minibatch(es)) have been sent to the engine\n" + "INFO:pathway_engine.connectors.monitoring:PythonReader: 10 entries (3 minibatch(es)) have been sent to the engine\n" ] }, { "name": "stderr", "output_type": "stream", "text": [ - "WARNING:pathway_engine.connectors.monitoring:PythonReader-0: Closing the data source\n" + "WARNING:pathway_engine.connectors.monitoring:PythonReader: Closing the data source\n" ] }, { @@ -518,6 +525,13 @@ "text": [ "INFO:root:Total: 0\n" ] + }, + { + "name": "stderr", + "output_type": "stream", + "text": [ + "INFO:pathway_engine.connectors.monitoring:subscribe-0: Done writing 23 entries, closing data sink. Current batch writes took: 0 ms. All writes so far took: 0 ms.\n" + ] } ], "source": [ diff --git a/examples/notebooks/tutorials/udf.ipynb b/examples/notebooks/tutorials/udf.ipynb index c7f03a43..3809f384 100644 --- a/examples/notebooks/tutorials/udf.ipynb +++ b/examples/notebooks/tutorials/udf.ipynb @@ -893,7 +893,13 @@ "inc_async(0.6) starting\n", "inc_async(2.0) starting\n", "inc_async(0.2) starting\n", - "inc_async(1.2) starting\n", + "inc_async(1.2) starting\n" + ] + }, + { + "name": "stdout", + "output_type": "stream", + "text": [ "inc_async(0.2) finishing\n" ] },