diff options
Diffstat (limited to 'src')
-rwxr-xr-x | src/flufigut.py | 8 |
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), |