Total Complexity | 6 |
Total Lines | 33 |
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 | process (CallsProcess): process which will be incrementally build |
||
14 | """ |
||
15 | |||
16 | 1 | def __init__(self, structure_type, how_many_nodes): |
|
17 | """Constructor.""" |
||
18 | 1 | self._stages_to_add = [] |
|
19 | 1 | self.structure_type = structure_type |
|
20 | 1 | self.how_many_nodes = how_many_nodes |
|
21 | 1 | self.process = CallsProcess() |
|
22 | |||
23 | 1 | def _update_structure(self): |
|
24 | """Update structure of process.""" |
||
25 | 1 | if self.structure_type == "linear": |
|
26 | 1 | self.process.add_path(self._stages_to_add) |
|
27 | else: |
||
28 | 1 | raise NotImplementedError() |
|
29 | |||
30 | 1 | def _create_stages(self): |
|
31 | """Create stages which will be injected to process.""" |
||
32 | 1 | for i in range(self.how_many_nodes): |
|
33 | 1 | self._stages_to_add += [CallsStage(str(i))] |
|
34 | |||
35 | 1 | def construct_process(self): |
|
36 | """Construct process.""" |
||
37 | 1 | self._create_stages() |
|
38 | 1 | self._update_structure() |
|
39 | return self.process |
||
40 |