diff --git a/binaries/coordinator/examples/graphs/python_test.yml b/binaries/coordinator/examples/graphs/python_test.yml new file mode 100644 index 00000000..6d80c651 --- /dev/null +++ b/binaries/coordinator/examples/graphs/python_test.yml @@ -0,0 +1,29 @@ +communication: + zenoh: + prefix: /foo + +nodes: + - id: static-string + custom: + run: python examples/nodes/python/static_string.py + outputs: + - string + + - id: python-printer + custom: + run: python examples/nodes/python/printer.py + inputs: + time: static-string/string + time2: rust-timer/time + + - id: rust-timer + custom: + run: cargo run --example source_timer + outputs: + - time + + - id: rust-logger + custom: + run: cargo run --example sink_logger + inputs: + time: static-string/string \ No newline at end of file diff --git a/binaries/coordinator/examples/nodes/python/printer.py b/binaries/coordinator/examples/nodes/python/printer.py index 1a782847..b2fa18c7 100644 --- a/binaries/coordinator/examples/nodes/python/printer.py +++ b/binaries/coordinator/examples/nodes/python/printer.py @@ -1,9 +1,8 @@ from dora import PyDoraNode -node = PyDoraNode.init_from_env() +node = PyDoraNode() -for i in range(100): - value = node.next() - print(value) if value is not [] else None +for id, value in node: + print(f"From Python, id: {id}, value: {value}") if value is not [] else None print("printer finished") diff --git a/binaries/coordinator/examples/nodes/python/static_string.py b/binaries/coordinator/examples/nodes/python/static_string.py new file mode 100644 index 00000000..ee8c7aa7 --- /dev/null +++ b/binaries/coordinator/examples/nodes/python/static_string.py @@ -0,0 +1,11 @@ +import time + +from dora import PyDoraNode + +node = PyDoraNode() + +for i in range(100): + node.send_output("string", b"Hello World") + time.sleep(0.1) + +print("static string finished") diff --git a/binaries/coordinator/examples/nodes/python/timer.py b/binaries/coordinator/examples/nodes/python/timer.py deleted file mode 100644 index 4ac1596c..00000000 --- a/binaries/coordinator/examples/nodes/python/timer.py +++ /dev/null @@ -1,10 +0,0 @@ -from dora import PyDoraNode - -node = PyDoraNode.init_from_env() -import time - -for i in range(100): - node.send_output("time", b"awef") - time.sleep(0.1) - -print("printer finished")