Source Code for Module cm_api_tests.test_services

 1  # Licensed to Cloudera, Inc. under one 
 2  # or more contributor license agreements.  See the NOTICE file 
 3  # distributed with this work for additional information 
 4  # regarding copyright ownership.  Cloudera, Inc. licenses this file 
 5  # to you under the Apache License, Version 2.0 (the 
 6  # "License"); you may not use this file except in compliance 
 7  # with the License.  You may obtain a copy of the License at 
 8  # 
 9  #     http://www.apache.org/licenses/LICENSE-2.0 
10  # 
11  # Unless required by applicable law or agreed to in writing, software 
12  # distributed under the License is distributed on an "AS IS" BASIS, 
13  # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 
14  # See the License for the specific language governing permissions and 
15  # limitations under the License. 
16   
17  import unittest 
18  from cm_api.endpoints.clusters import ApiCluster 
19  from cm_api.endpoints.services import * 
20  from cm_api.endpoints.types import * 
21  from cm_api_tests import utils 
22   
23 -class TestService(unittest.TestCase): 
24   
25 -  def test_create_hdfs_tmp(self): 
26      resource = utils.MockResource(self) 
27      service = ApiService(resource, 'hdfs1', 'HDFS') 
28      service.__dict__['clusterRef'] = ApiClusterRef(resource, clusterName='cluster1') 
29   
30      resource.expect("POST", "/clusters/cluster1/services/hdfs1/commands/hdfsCreateTmpDir", 
31          retdata=ApiCommand(resource).to_json_dict()) 
32      service.create_hdfs_tmp() 
33