diff --git a/src/python/dm/daq_web_service/service/impl/experimentSessionControllerImpl.py b/src/python/dm/daq_web_service/service/impl/experimentSessionControllerImpl.py
index 1c73e3aa291ba5d2c33d4ceb04b154e5bcddb9be..8388702703f534adced3d6972fb8694c21a52c76 100755
--- a/src/python/dm/daq_web_service/service/impl/experimentSessionControllerImpl.py
+++ b/src/python/dm/daq_web_service/service/impl/experimentSessionControllerImpl.py
@@ -4,6 +4,7 @@
 # Implementation for experiment session controller.
 #
 
+import os
 import time
 
 from dm.common.objects.experiment import Experiment
@@ -24,6 +25,8 @@ class ExperimentSessionControllerImpl(DmObjectManager):
         self.dsExperimentApi = DsRestApiFactory.getExperimentRestApi()
 
     def startDaq(self, experimentName, dataDirectory, daqInfo):
+        if not os.path.exists(dataDirectory):
+           os.makedirs(dataDirectory)
         if daqInfo is None:
            daqInfo={}
 	   daqInfo['experimentName'] = experimentName