Skip to content

Commit 75da981

Browse files
committed
msgflo-python: Fix exceptions, not passing role and wrong run()
1 parent fb0e42a commit 75da981

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

bin/msgflo-python

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ def main():
3333
module = load_module_file(modulepath)
3434
classes = find_participant_classes(module)
3535
Participant = classes[0]
36-
msgflo.main(Participant)
36+
msgflo.main(Participant, role)
3737

3838
if __name__ == '__main__':
3939
logging.basicConfig()

msgflo/msgflo.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -289,11 +289,11 @@ def run(participant, broker=None, done_cb=None):
289289

290290
return engine
291291

292-
def main(Participant):
292+
def main(Participant, role):
293293
participant = Participant(role)
294294
d = participant.definition
295295
waiter = gevent.event.AsyncResult()
296-
engine = msgflo.run(participant, done_cb=waiter.set)
296+
engine = run(participant, done_cb=waiter.set)
297297
print "%s(%s) running on %s" % (d['role'], d['component'], engine.broker_url)
298298
sys.stdout.flush()
299299
waiter.wait()

0 commit comments

Comments
 (0)