diff --git a/SAS/DataManagement/DataManagementCommon/path.py b/SAS/DataManagement/DataManagementCommon/path.py index ecace76aa33bd09eb6bfc204bbd822ba19e48080..98c60842722057d4ff4c062509b0d3b2934d7d42 100644 --- a/SAS/DataManagement/DataManagementCommon/path.py +++ b/SAS/DataManagement/DataManagementCommon/path.py @@ -75,9 +75,15 @@ class PathResolver: path_result = {'found': True, 'message': '', 'path': task_data_path} if task['type'] == 'pipeline': + path_result['scratch_paths'] = [] + scratch_path = os.path.join(self.scratch_path, 'Observation%s' % task['otdb_id']) + if self.pathExists(scratch_path): + path_result['scratch_paths'].append(scratch_path) + share_path = os.path.join(self.share_path, 'Observation%s' % task['otdb_id']) - path_result['scratch_paths'] = [scratch_path, share_path] + if self.pathExists(share_path): + path_result['scratch_paths'].append(share_path) return path_result