Completed
Pull Request — master (#515)
by
unknown
03:08
created

UpdateNodePoller   A

Complexity

Total Complexity 3

Size/Duplication

Total Lines 37
Duplicated Lines 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
dl 0
loc 37
rs 10
c 1
b 0
f 0
wmc 3

1 Method

Rating   Name   Duplication   Size   Complexity  
B run() 0 36 3
1
# Licensed to the StackStorm, Inc ('StackStorm') under one or more
2
# contributor license agreements.  See the NOTICE file distributed with
3
# this work for additional information regarding copyright ownership.
4
# The ASF licenses this file to You under the Apache License, Version 2.0
5
# (the "License"); you may not use this file except in compliance with
6
# the License.  You may obtain a copy of the License at
7
#
8
#     http://www.apache.org/licenses/LICENSE-2.0
9
#
10
# Unless required by applicable law or agreed to in writing, software
11
# distributed under the License is distributed on an "AS IS" BASIS,
12
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
# See the License for the specific language governing permissions and
14
# limitations under the License.
15
16
from lib.actions import OrionBaseAction
17
from lib.utils import send_user_error
18
19
20
class UpdateNodePoller(OrionBaseAction):
21
    def run(self, platform, node, poller):
22
        """
23
        Change the poller for an Orion Node.
24
25
        Args:
26
        - node: The caption in Orion of the node to poll.
27
        - poller: The poller to change the node too.
28
        - platform: The orion platform to act on.
29
30
        Returns
31
        - True: As PollNow does not return any data.
32
33
        Raises:
34
        - ValueError: When a node is not found.
35
        """
36
37
        self.connect(platform)
38
39
        orion_node = self.get_node(node)
40
41
        if not orion_node.npm:
42
            error_msg = "Node not found"
43
            send_user_error(error_msg)
44
            raise ValueError(error_msg)
45
46
        engine_id = self.get_engine_id(poller)
47
48
        kargs = {"EngineID": engine_id}
49
50
        orion_data = self.update(orion_node.uri, **kargs)
51
52
        # This Invoke always returns None, so check and return True
53
        if orion_data is None:
54
            return True
55
        else:
56
            return orion_data
57