diff options
author | Dmitrii Agibov <dmitrii.agibov@arm.com> | 2022-07-21 14:06:03 +0100 |
---|---|---|
committer | Benjamin Klimczak <benjamin.klimczak@arm.com> | 2022-08-19 10:23:23 +0100 |
commit | a8ee1aee3e674c78a77801d1bf2256881ab6b4b9 (patch) | |
tree | 8463b24ba0446a49b3e012477b0834c3b5415b86 /src/mlia/core/workflow.py | |
parent | 76ec769ad8f8ed53ec3ff829fdd34d53db8229fd (diff) | |
download | mlia-a8ee1aee3e674c78a77801d1bf2256881ab6b4b9.tar.gz |
MLIA-549 Refactor API module to support several target profiles
- Move target specific details out of API module
- Move common logic for workflow event handler into a
separate class
Change-Id: Ic4a22657b722af1c1fead1d478f606ac57325788
Diffstat (limited to 'src/mlia/core/workflow.py')
-rw-r--r-- | src/mlia/core/workflow.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mlia/core/workflow.py b/src/mlia/core/workflow.py index 0245087..03f3d1c 100644 --- a/src/mlia/core/workflow.py +++ b/src/mlia/core/workflow.py @@ -87,7 +87,7 @@ class DefaultWorkflowExecutor(WorkflowExecutor): collectors: Sequence[DataCollector], analyzers: Sequence[DataAnalyzer], producers: Sequence[AdviceProducer], - before_start_events: Optional[Sequence[Event]] = None, + startup_events: Optional[Sequence[Event]] = None, ): """Init default workflow executor. @@ -95,14 +95,14 @@ class DefaultWorkflowExecutor(WorkflowExecutor): :param collectors: List of the data collectors :param analyzers: List of the data analyzers :param producers: List of the advice producers - :param before_start_events: Optional list of the custom events that + :param startup_events: Optional list of the custom events that should be published before start of the worfkow execution. """ self.context = context self.collectors = collectors self.analyzers = analyzers self.producers = producers - self.before_start_events = before_start_events + self.startup_events = startup_events def run(self) -> None: """Run the workflow.""" @@ -125,7 +125,7 @@ class DefaultWorkflowExecutor(WorkflowExecutor): def before_start(self) -> None: """Run actions before start of the workflow execution.""" - events = self.before_start_events or [] + events = self.startup_events or [] for event in events: self.publish(event) |