This website works better with JavaScript.
Home
Issues
Pull Requests
Milestones
AI流水线
Repositories
Datasets
Forum
实训
竞赛
大数据
AI开发
Register
Sign In
dora-rs
/
dora
Not watched
Unwatch
Watch all
Watch but not notify
1
Star
0
Fork
0
Code
Releases
124
Wiki
evaluate
Activity
Issues
0
Pull Requests
0
Datasets
Model
Cloudbrain
HPC
Browse Source
Adding test graph for python node
tags/v0.0.0-test.4
haixuanTao
3 years ago
parent
d69776a85f
commit
79da342b62
4 changed files
with
43 additions
and
14 deletions
Split View
Diff Options
Show Stats
Download Patch File
Download Diff File
+29
-0
binaries/coordinator/examples/graphs/python_test.yml
+3
-4
binaries/coordinator/examples/nodes/python/printer.py
+11
-0
binaries/coordinator/examples/nodes/python/static_string.py
+0
-10
binaries/coordinator/examples/nodes/python/timer.py
+ 29
- 0
binaries/coordinator/examples/graphs/python_test.yml
View File
@@ -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
+ 3
- 4
binaries/coordinator/examples/nodes/python/printer.py
View File
@@ -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")
+ 11
- 0
binaries/coordinator/examples/nodes/python/static_string.py
View File
@@ -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")
+ 0
- 10
binaries/coordinator/examples/nodes/python/timer.py
View File
@@ -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")
Write
Preview
Loading…
Cancel
Save