aboutsummaryrefslogtreecommitdiff
path: root/src/mlia/core/workflow.py
diff options
context:
space:
mode:
authorDmitrii Agibov <dmitrii.agibov@arm.com>2022-07-21 14:06:03 +0100
committerBenjamin Klimczak <benjamin.klimczak@arm.com>2022-08-19 10:23:23 +0100
commita8ee1aee3e674c78a77801d1bf2256881ab6b4b9 (patch)
tree8463b24ba0446a49b3e012477b0834c3b5415b86 /src/mlia/core/workflow.py
parent76ec769ad8f8ed53ec3ff829fdd34d53db8229fd (diff)
downloadmlia-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.py8
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)