Total Complexity | 6 |
Total Lines | 35 |
Duplicated Lines | 0 % |
Coverage | 100% |
1 | """Contains factory class of process with calls stages.""" |
||
7 | 1 | class CallsProcessFactory: |
|
8 | """Class which produce process with the same type of stages. |
||
9 | |||
10 | Attributes: |
||
11 | structure_type (str): represent type of structure |
||
12 | how_many_nodes (int): how many nodes should be in generated process |
||
13 | max_calls (int): max_calls for stages |
||
14 | process (CallsProcess): process which will be incrementally build |
||
15 | """ |
||
16 | |||
17 | 1 | def __init__(self, structure_type, how_many_nodes, max_calls): |
|
18 | """Constructor.""" |
||
19 | 1 | self.max_calls = max_calls |
|
20 | 1 | self._stages_to_add = [] |
|
21 | 1 | self.structure_type = structure_type |
|
22 | 1 | self.how_many_nodes = how_many_nodes |
|
23 | 1 | self.process = CallsProcess() |
|
24 | |||
25 | 1 | def _update_structure(self): |
|
26 | """Update structure of process.""" |
||
27 | 1 | if self.structure_type == "linear": |
|
28 | 1 | self.process.add_path(self._stages_to_add) |
|
29 | else: |
||
30 | 1 | raise NotImplementedError() |
|
31 | |||
32 | 1 | def _create_stages(self): |
|
33 | """Create stages which will be injected to process.""" |
||
34 | 1 | for i in range(self.how_many_nodes): |
|
35 | 1 | self._stages_to_add += [CallsStage(str(i), self.max_calls)] |
|
36 | |||
37 | 1 | def construct_process(self): |
|
38 | """Construct process.""" |
||
39 | 1 | self._create_stages() |
|
40 | 1 | self._update_structure() |
|
41 | return self.process |
||
42 |