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 c467c729e58c80520a5aaa7231f20e4502543282..5f42e727ec93c53d88a8db904cc4705b82203715 100755
--- a/src/python/dm/daq_web_service/service/impl/experimentSessionControllerImpl.py
+++ b/src/python/dm/daq_web_service/service/impl/experimentSessionControllerImpl.py
@@ -20,19 +20,18 @@ from fileSystemObserver import FileSystemObserver
 class ExperimentSessionControllerImpl(DmObjectManager):
     """ Experiment session controller implementation class. """
 
+    DAQ_PERMISSIONS_MODE = 0777
+
     def __init__(self):
         DmObjectManager.__init__(self)
         self.dsExperimentApi = DsRestApiFactory.getExperimentRestApi()
 
     def startDaq(self, experimentName, dataDirectory, daqInfo):
-        if not os.path.exists(dataDirectory):
-           os.makedirs(dataDirectory)
-           mode = 0777
-           os.chmod(dataDirectory, mode)
+        OsUtility.createDir(dataDirectory, mode=self.DAQ_PERMISSIONS_MODE)
         if daqInfo is None:
-           daqInfo={}
-	   daqInfo['experimentName'] = experimentName
-	   daqInfo['dataDirectory'] = dataDirectory
+            daqInfo={}
+	    daqInfo['experimentName'] = experimentName
+	    daqInfo['dataDirectory'] = dataDirectory
         experiment = ExperimentTracker.getInstance().get(experimentName)
         if experiment is not None:
             oldDaqInfo = experiment.get('daqInfo')