fixed bug where a whole stream cluster gets ignored if no needed worker is assigned to any machine

1 files changed, 4 insertions, 4 deletions

diff --git a/src/flufigut.py b/src/flufigut.py
index bdb8737..582f07e 100755
--- a/src/flufigut.py
+++ b/src/flufigut.py
@@ -265,6 +265,10 @@ if output_format == 'flumotion':
     port = stream[cluster]['port']
     for idx in range(streamer_cnt):
       stream_worker = '%s%i'%(cluster, idx+1)
+      if stream_worker not in worker:
+        worker[stream_worker] = -1
+      else:
+        worker[stream_worker] = 1
       for machine in globals['machines'].keys():
         if stream_worker in globals['machines'][machine]:
           if machine in machines:
@@ -282,10 +286,6 @@ if output_format == 'flumotion':
             'password': rand_string(size=12),
             }
 
-          if stream_worker not in worker:
-            worker[stream_worker] = -1
-          else:
-            worker[stream_worker] = 1
           atmosphere['porter-%s-%i'%(machine, port)] = {
             'type': "porter",
             'desc': "Porter for %s on port %i"%(machine, port),