diff --git a/SAS/ResourceAssignment/ResourceAssignmentEstimator/service.py b/SAS/ResourceAssignment/ResourceAssignmentEstimator/service.py
index 0dbadd795c067f7b029588c8a4d1f329064d6f95..0f2031fc96da69c5e0143944eb6546bbe70f7d16 100644
--- a/SAS/ResourceAssignment/ResourceAssignmentEstimator/service.py
+++ b/SAS/ResourceAssignment/ResourceAssignmentEstimator/service.py
@@ -59,8 +59,8 @@ class ResourceEstimatorHandler(MessageHandlerInterface):
             logger.info(("Branch estimates for %s\n" % otdb_id) + pprint.pformat(branch_estimates)) 
 
             if specification_tree['task_subtype'] in ['averaging pipeline', 'calibration pipeline']:
+                input_files = {}
                 for id, estimate in branch_estimates.iteritems():
-                    input_files = {}
                     predecessor_output = estimate.values()[0]['storage']['output_files']
                     if not 'im' in predecessor_output and 'uv' in predecessor_output: # Not a calibrator pipeline
                         logger.info('found %s as the target of pipeline %s' % (id, otdb_id))