Passed
Push — master ( b89bc6...e48c8f )
by Plexxi
03:34
created

BaseConcurrencyApplicator   A

Complexity

Total Complexity 4

Size/Duplication

Total Lines 16
Duplicated Lines 0 %

Importance

Changes 2
Bugs 0 Features 0
Metric Value
c 2
b 0
f 0
dl 0
loc 16
rs 10
wmc 4

2 Methods

Rating   Name   Duplication   Size   Complexity  
A _get_status_for_policy_action() 0 7 3
A __init__() 0 7 1
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 st2common.constants import action as action_constants
17
from st2common.policies import base
18
from st2common.services import coordination
19
20
__all__ = [
21
    'BaseConcurrencyApplicator'
22
]
23
24
25
class BaseConcurrencyApplicator(base.ResourcePolicyApplicator):
26
    def __init__(self, policy_ref, policy_type, threshold=0, action='delay'):
27
        super(BaseConcurrencyApplicator, self).__init__(policy_ref=policy_ref,
28
                                                        policy_type=policy_type)
29
        self.threshold = threshold
30
        self.policy_action = action
31
32
        self.coordinator = coordination.get_coordinator()
33
34
    def _get_status_for_policy_action(self, action):
35
        if action == 'delay':
36
            status = action_constants.LIVEACTION_STATUS_DELAYED
37
        elif action == 'cancel':
38
            status = action_constants.LIVEACTION_STATUS_CANCELED
39
40
        return status
41