diff --git a/src/python/dm/ds_web_service/service/impl/mongoDbFileCatalogPlugin.py b/src/python/dm/ds_web_service/service/impl/mongoDbFileCatalogPlugin.py
index 11ea3be2415ede18990fce7bd167f5f16d362d18..5796944a119b211b3ee56888b3a55a55e817604e 100755
--- a/src/python/dm/ds_web_service/service/impl/mongoDbFileCatalogPlugin.py
+++ b/src/python/dm/ds_web_service/service/impl/mongoDbFileCatalogPlugin.py
@@ -16,13 +16,13 @@ class MongoDbFileCatalogPlugin(FileProcessor):
 
     def processFile(self, fileInfo):
         experimentFilePath = fileInfo.get('experimentFilePath')
-        experiment = fileInfo.get('experiment')
-        experimentName = experiment.get('name')
+        experimentName = fileInfo.get('experimentName')
         self.logger.debug('Processing file %s for experiment %s' % (fileInfo, experimentName))
 
-        experimentStorageDirectory = experiment.get('storageDirectory')
-        storageHost = experiment.get('storageHost')
-        storageFilePath = os.path.join(experimentStorageDirectory, experimentFilePath)
+        daqInfo = fileInfo.get('daqInfo')
+        storageDirectory = daqInfo.get('storageDirectory')
+        storageHost = daqInfo.get('storageHost')
+        storageFilePath = os.path.join(storageDirectory, experimentFilePath)
         fileProcessingTime = time.time()
         fileProcessingTimeStamp = TimeUtility.formatLocalTimeStamp(fileProcessingTime)
 
@@ -32,14 +32,19 @@ class MongoDbFileCatalogPlugin(FileProcessor):
             if fileInfo.has_key(key):
                 fileInfo2[key] = fileInfo.get(key, '')
         fileInfo2['fileName'] = os.path.basename(experimentFilePath)
-        fileInfo2['experimentStorageDirectory'] = experimentStorageDirectory
+        fileInfo2['storageDirectory'] = storageDirectory
         fileInfo2['storageHost'] = storageHost
         fileInfo2['storageFilePath'] = storageFilePath
         fileInfo2['experimentFilePath'] = experimentFilePath
         fileInfo2['experimentName'] = experimentName
         fileInfo2['fileProcessingTime'] = fileProcessingTime
         fileInfo2['fileProcessingTimeStamp'] = fileProcessingTimeStamp
-        fileInfo2.update(fileInfo.get('daqInfo', {}))
+        self.logger.debug('Daq info: %s' % (daqInfo))
+        fileInfo2.update(daqInfo)
+        if daqInfo.has_key('id'): 
+            fileInfo2['daqId'] = daqInfo.get('id')
+            del fileInfo2['id']
+
         self.fileMongoDbApi.updateOrAddExperimentFile(fileInfo2)
 
 
diff --git a/src/python/dm/ds_web_service/service/impl/scriptProcessingPlugin.py b/src/python/dm/ds_web_service/service/impl/scriptProcessingPlugin.py
index 75be4c78eaa81295450f7e54a1520ff93c7bde80..c892f6ddfec6b276430414160498affcaa12e719 100755
--- a/src/python/dm/ds_web_service/service/impl/scriptProcessingPlugin.py
+++ b/src/python/dm/ds_web_service/service/impl/scriptProcessingPlugin.py
@@ -18,8 +18,7 @@ class ScriptProcessingPlugin(FileProcessor):
         self.logger = LoggingManager.getInstance().getLogger(self.__class__.__name__)
 
     def processFile(self, fileInfo):
-        experiment = fileInfo.get('experiment')
-        experimentName = experiment.get('name')
+        experimentName = fileInfo.get('experimentName')
         experimentFilePath = fileInfo.get('experimentFilePath')
         daqInfo = fileInfo.get('daqInfo', {})
         processingScript = daqInfo.get(self.PROCESSING_SCRIPT_KEY)
@@ -29,8 +28,8 @@ class ScriptProcessingPlugin(FileProcessor):
   
         self.logger.debug('Processing file %s for experiment %s' % (experimentFilePath, experimentName))
 
-        experimentStorageDirectory = experiment.get('storageDirectory')
-        storageFilePath = os.path.join(experimentStorageDirectory, experimentFilePath)
+        storageDirectory = fileInfo.get('storageDirectory')
+        storageFilePath = os.path.join(storageDirectory, experimentFilePath)
 
         # Process file
         try:
diff --git a/src/python/dm/ds_web_service/service/impl/sddsParameterProcessingPlugin.py b/src/python/dm/ds_web_service/service/impl/sddsParameterProcessingPlugin.py
index ed2f8f35b01ce61d03a3ab45de27fc4bc510895b..54c99808a31d6e04b00eb76f05e91d36e49517b4 100755
--- a/src/python/dm/ds_web_service/service/impl/sddsParameterProcessingPlugin.py
+++ b/src/python/dm/ds_web_service/service/impl/sddsParameterProcessingPlugin.py
@@ -19,8 +19,7 @@ class SddsParameterProcessingPlugin(FileProcessor):
 
     def processFile(self, fileInfo):
         experimentFilePath = fileInfo.get('experimentFilePath')
-        experiment = fileInfo.get('experiment')
-        experimentName = experiment.get('name')
+        experimentName = fileInfo.get('experimentName')
         daqInfo = fileInfo.get('daqInfo', {})
         processSddsParameters = daqInfo.get(self.PROCESS_SDDS_PARAMETERS_KEY)
         if not processSddsParameters:
@@ -29,8 +28,8 @@ class SddsParameterProcessingPlugin(FileProcessor):
 
         self.logger.debug('Processing file %s for experiment %s' % (fileInfo, experimentName))
 
-        experimentStorageDirectory = experiment.get('storageDirectory')
-        storageFilePath = os.path.join(experimentStorageDirectory, experimentFilePath)
+        storageDirectory = fileInfo.get('storageDirectory')
+        storageFilePath = os.path.join(storageDirectory, experimentFilePath)
 
         # Load file
         try:
diff --git a/src/python/dm/ds_web_service/service/impl/sgeJobSubmissionPlugin.py b/src/python/dm/ds_web_service/service/impl/sgeJobSubmissionPlugin.py
index 42ccb7ec083f84ee62339f0dd50e28cee3869e67..a63e71343fa2859bf82d85adb82550ccc650e264 100755
--- a/src/python/dm/ds_web_service/service/impl/sgeJobSubmissionPlugin.py
+++ b/src/python/dm/ds_web_service/service/impl/sgeJobSubmissionPlugin.py
@@ -17,8 +17,7 @@ class SgeJobSubmissionPlugin(FileProcessor):
         self.logger = LoggingManager.getInstance().getLogger(self.__class__.__name__)
 
     def processFile(self, fileInfo):
-        experiment = fileInfo.get('experiment')
-        experimentName = experiment.get('name')
+        experimentName = fileInfo.get('experimentName')
         experimentFilePath = fileInfo.get('experimentFilePath')
         daqInfo = fileInfo.get('daqInfo', {})
         sgeJobScript = daqInfo.get(self.SGE_JOB_SCRIPT_KEY)
@@ -28,8 +27,8 @@ class SgeJobSubmissionPlugin(FileProcessor):
   
         self.logger.debug('Processing file %s for experiment %s' % (experimentFilePath, experimentName))
 
-        experimentStorageDirectory = experiment.get('storageDirectory')
-        storageFilePath = os.path.join(experimentStorageDirectory, experimentFilePath)
+        storageDirectory = fileInfo.get('storageDirectory')
+        storageFilePath = os.path.join(storageDirectory, experimentFilePath)
 
         # Process file
         try: