Pass storm workers to topology on deploy as storm.workers.list (#395)

pystorm · Aug 30, 2017 · bb82277 · bb82277
1 parent 32e97d3
commit bb82277
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/streamparse/cli/common.py b/streamparse/cli/common.py
@@ -230,8 +230,10 @@ def resolve_options(cli_options, env_config, topology_class, topology_name,
 
     # If ackers and executors still aren't set, use number of worker nodes
     if not local_only:
-        num_storm_workers = len(get_storm_workers(env_config))
+        storm_options['storm.workers.list'] = get_storm_workers(env_config)
+        num_storm_workers = len(storm_options['storm.workers.list'])
     else:
+        storm_options['storm.workers.list'] = []
         num_storm_workers = 1
     if storm_options.get('topology.acker.executors') is None:
         storm_options['topology.acker.executors'] = num_storm_workers