x/solar
Code Issues Proposed changes

One more signals fix in riak example

Browse Source
This commit is contained in:
Jedrzej Nowak 2015-08-21 13:18:37 +02:00
parent dea67d5d8a
commit 7dd79ac771
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
example-riaks.py
View File

@ -42,7 +42,7 @@ def setup_riak():
signals.connect(nodes[i], riak)
for i, riak in enumerate(riak_services[1:]):
signals.connect(riak_services[0], riak, {'riak_name': 'join_to'})
signals.connect(riak_services[0], riak, {'riak_name': 'join_to'}, events=None)
hosts_services = []
for i, riak in enumerate(riak_services):
@ -80,14 +80,11 @@ def setup_riak():
Dep('hosts_file2', 'run', 'success', 'riak_service2', 'run'),
Dep('hosts_file3', 'run', 'success', 'riak_service3', 'run'),
React('riak_service1', 'run', 'success', 'riak_service2', 'join'),
React('riak_service1', 'run', 'success', 'riak_service3', 'join'),
React('riak_service2', 'run', 'success', 'riak_service2', 'join'),
React('riak_service3', 'run', 'success', 'riak_service3', 'join'),
Dep('riak_service2', 'run', 'success', 'riak_service2', 'join'),
Dep('riak_service3', 'run', 'success', 'riak_service3', 'join'),
# React('riak_service2', 'run', 'success', 'riak_service2', 'join'),
# React('riak_service3', 'run', 'success', 'riak_service3', 'join'),
# Dep('riak_service1', 'run', 'success', 'riak_service2', 'join'),
# Dep('riak_service1', 'run', 'success', 'riak_service3', 'join'),
React('riak_service3', 'join', 'success', 'riak_service1', 'commit'),
React('riak_service2', 'join', 'success', 'riak_service1', 'commit')