diff --git a/storm-multilang/python/src/main/resources/resources/storm.py b/storm-multilang/python/src/main/resources/resources/storm.py index 9106390b499..16fa82fcd41 100755 --- a/storm-multilang/python/src/main/resources/resources/storm.py +++ b/storm-multilang/python/src/main/resources/resources/storm.py @@ -109,7 +109,7 @@ def emitBolt(tup, stream=None, anchors = [], directTask=None): m = {"command": "emit"} if stream is not None: m["stream"] = stream - m["anchors"] = map(lambda a: a.id, anchors) + m["anchors"] = list(map(lambda a: a.id, anchors)) if directTask is not None: m["task"] = directTask m["tuple"] = tup