renamed worker variable

1 files changed, 4 insertions, 4 deletions

diff --git a/src/flufigut.py b/src/flufigut.py
index 83c4e84..a27060e 100755
--- a/src/flufigut.py
+++ b/src/flufigut.py
@@ -192,9 +192,9 @@ for cluster in stream.keys():
   streamer_cnt = stream[cluster]['count']
   port = stream[cluster]['port']
   for idx in range(streamer_cnt):
-    worker = '%s%i'%(cluster, idx+1)
+    stream_worker = '%s%i'%(cluster, idx+1)
     for machine in globals['machines'].keys():
-      if worker in globals['machines'][machine]:
+      if stream_worker in globals['machines'][machine]:
         if machine in machines:
           if 'porter' in machines[machine]:
             if port in machines[machine]['porter']:
@@ -213,7 +213,7 @@ for cluster in stream.keys():
         atmosphere['porter-%s-%i'%(machine, port)] = {
           'type': "porter",
           'desc': "Porter for %s on port %i"%(machine, port),
-          'worker': worker,
+          'worker': stream_worker,
           'properties': {
             'port': port,
             'socket-path': machines[machine]['porter'][port]['socket-path'],
@@ -238,7 +238,7 @@ for cluster in stream.keys():
             flow['streamer'][name] = {
               'type': "%s-stream" % stream[cluster]['type'],
               'desc': "%s streamer for %s-%s (part %i of %s cluster)" % (stream[cluster]['type'], format, profile, idx+1, cluster),
-              'worker': worker,
+              'worker': stream_worker,
               'feeder': feeder,
               'rrd_clients' : "%s/%s_clients.rrd" % (globals['rrd-dir'], name),
               'rrd_bytes' : "%s/%s_bytes.rrd" % (globals['rrd-dir'], name),