From 79da342b62cc1557422969e045a99a8d3a89c965 Mon Sep 17 00:00:00 2001
From: haixuanTao <tao.xavier@outlook.com>
Date: Fri, 29 Jul 2022 16:05:10 +0200
Subject: [PATCH] Adding test graph for python node

---
 .../examples/graphs/python_test.yml           | 29 +++++++++++++++++++
 .../examples/nodes/python/printer.py          |  7 ++---
 .../examples/nodes/python/static_string.py    | 11 +++++++
 .../examples/nodes/python/timer.py            | 10 -------
 4 files changed, 43 insertions(+), 14 deletions(-)
 create mode 100644 binaries/coordinator/examples/graphs/python_test.yml
 create mode 100644 binaries/coordinator/examples/nodes/python/static_string.py
 delete mode 100644 binaries/coordinator/examples/nodes/python/timer.py

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")