#!/usr/bin/env python from dm.cat_web_service.api.fileRestApi import FileRestApi from dm.common.exceptions.invalidRequest import InvalidRequest from catWebServiceSessionCli import CatWebServiceSessionCli class UpdateExperimentFileCli(CatWebServiceSessionCli): def __init__(self): CatWebServiceSessionCli.__init__(self, validArgCount=self.ANY_NUMBER_OF_POSITIONAL_ARGS) self.addOption('', '--file', dest='experimentFilePath', help='Experiment file path.') self.addOption('', '--experiment', dest='experimentName', help='Experiment name.') def checkArgs(self): if self.options.experimentName is None: raise InvalidRequest('Experiment name must be provided.') if self.options.experimentFilePath is None: raise InvalidRequest('Experiment file path must be provided.') def getExperimentName(self): return self.options.experimentName def getExperimentFilePath(self): return self.options.experimentFilePath def runCommand(self): self.parseArgs(usage=""" dm-update-experiment-file --file=EXPERIMENTFILEPATH --experiment=EXPERIMENTNAME [key1:value1, key2:value2, ...] Description: Updates experiment file in the metadata catalog. All provided key/value pairs are interpreted as file metadata, and will be merged with existing metadata, overwriting values for existing keys, and adding values for new keys. """) self.checkArgs() api = FileRestApi(self.getLoginUsername(), self.getLoginPassword(), self.getServiceHost(), self.getServicePort(), self.getServiceProtocol()) fileInfo = self.splitArgsIntoDict() fileInfo['experimentName'] = self.getExperimentName() fileInfo['experimentFilePath'] = self.getExperimentFilePath() fileMetadata = api.updateExperimentFile(fileInfo) print fileMetadata.getDisplayString(self.getDisplayKeys(), self.getDisplayFormat()) ####################################################################### # Run command. if __name__ == '__main__': cli = UpdateExperimentFileCli() cli.run()