Apache Stormはpython boltから関数を呼び出す

Question

私は他のpythonモジュールから関数を呼び出すだけでよい単純なstorm boltを持っています。関数内にprintステートメントを持つメソッドを呼び出すまでは、すべて動作します。

だから私のボルト：

import storm 
from pipeline import module as m 

class ExampleBolt(storm.BasicBolt): 

    def initialize(self, conf, context): 
     self._conf = conf; 
     self._context = context; 
     storm.logInfo("ExampleBolt instance starting ...") 

    def process(self, tuple): 
     id, text = tuple.values 
     result = m.dummy_funct(text)   
     storm.emit([result])   


ExampleBolt().run() 

方法：

def dummy_funct(text): 
    print "log info" 
    return text 

ボルトがメソッドを一度呼び出し、出力にハングアップします。 Apache Stormを使用する0.9.3

Answer 1

2回目以降のプロセスブロックが実行されているかどうかを確認します。
プログラム全体が実行されているわけではありません。