diff --git a/src/python/dm/common/utility/ftpUtility.py b/src/python/dm/common/utility/ftpUtility.py index ab6f03146e13f9b4b90361973627e8001af13a83..8a75aed46f25d0ed5805ca8d33ca6486bc6b9ba0 100755 --- a/src/python/dm/common/utility/ftpUtility.py +++ b/src/python/dm/common/utility/ftpUtility.py @@ -82,6 +82,6 @@ class FtpUtility: # Testing. if __name__ == '__main__': - ftpUtility = FtpUtility('zagreb', 2811) - files=ftpUtility.getFiles('/tmp/test') + ftpUtility = FtpUtility('s8dserv', 2811) + files=ftpUtility.getFiles('/export/8-id-i/test') print files 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 c047191b20cf0088144e83df7bf61b85dcb348c6..07085c6d180fb1717b6bd48f664dd47dd0d3662a 100755 --- a/src/python/dm/daq_web_service/service/impl/experimentSessionControllerImpl.py +++ b/src/python/dm/daq_web_service/service/impl/experimentSessionControllerImpl.py @@ -86,7 +86,12 @@ class ExperimentSessionControllerImpl(DmObjectManager): fileInfo['daqInfo'] = daqInfo fileInfo['uploadId'] = uploadId fileUploadInfo = { 'processed' : False } - FileUtility.statFile(filePath, fileUploadInfo) + # Stat should be done by agent, not by observer. + try: + FileUtility.statFile(filePath, fileUploadInfo) + except: + # Ok, may be remote file + pass fileDict[filePath] = fileUploadInfo fileProcessingManager.processFile(fileInfo) uploadInfo['fileDict'] = fileDict