-
Notifications
You must be signed in to change notification settings - Fork 0
/
example_cfg.yml
44 lines (37 loc) · 1.19 KB
/
example_cfg.yml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
node: !Node
- !chain
- !from example.random: {}
- .timing.every: {seconds: 0.1}
- .tqdm.counter: {desc: 'generated:'}
- !to [process_positive, process_high]
- !chain:process_positive
- example.threshold: {val: 0}
- .output.dump: {prefix: 'POSITIVE:'}
- example.Buffer: {}
- .timing.every: {seconds: 5}
- .output.dump: {prefix: 'Buffered positives:'}
- example.count
- .output.dump: {prefix: 'Values>0: '}
- !chain:process_high
- example.threshold: {val: 3}
- example.Buffer: {}
- .timing.every: {seconds: 5}
- example.count
- .output.dump: {prefix: 'Values>3: '}
node_parallel: !Node
- !chain
- !from example.gen_timestamp: {}
- .timing.every: {seconds: 1}
- snap.Parallel:
function: !obj:example.blocking {delay: 2.0}
executor: 'process'
max_workers: 20
- example.measure_latency
- .output.dump: {prefix: "latency: "}
node_blocking: !Node
- !chain
- !from example.gen_timestamp: {}
- .timing.every: {seconds: 1}
- example.blocking: {delay: 1.2}
- example.measure_latency
- .output.dump: {prefix: "latency: "}