Skip to content
Snippets Groups Projects
Commit 0a2c0db9 authored by Wout De Nolf's avatar Wout De Nolf
Browse files

Merge branch 'ppf_log_level_argument' into 'main'

add ppf_log_level argument for MX

See merge request !53
parents d85af3c2 f986fe2c
No related branches found
Tags v0.1.0-rc.1
1 merge request!53add ppf_log_level argument for MX
Pipeline #69440 passed
from .bindings import execute_graph # noqa: F401
__version__ = "0.1.0-rc"
__version__ = "0.1.0-rc.1"
......@@ -255,12 +255,9 @@ class InputMergeActor(AbstractActor):
class EwoksWorkflow(Workflow):
def __init__(
self,
ewoksgraph: TaskGraph,
):
def __init__(self, ewoksgraph: TaskGraph, ppf_log_level=logging.WARNING):
name = repr(ewoksgraph)
super().__init__(name, level=logging.WARNING)
super().__init__(name, level=ppf_log_level)
# When triggering a task, the output dict of the previous task
# is merged with the input dict of the current task.
......@@ -571,10 +568,11 @@ def execute_graph(
graph,
inputs: Optional[List[dict]] = None,
load_options: Optional[dict] = None,
ppf_log_level: int = logging.WARNING,
**execute_options,
):
if load_options is None:
load_options = dict()
ewoksgraph = load_graph(graph, inputs=inputs, **load_options)
ppfgraph = EwoksWorkflow(ewoksgraph)
ppfgraph = EwoksWorkflow(ewoksgraph, ppf_log_level=ppf_log_level)
return ppfgraph.run(**execute_options)
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment