Commit 4f8ef17a authored by Wout De Nolf's avatar Wout De Nolf
Browse files

remove the ppf_log_level argument

parent 0a2c0db9
Pipeline #69648 passed with stages
in 1 minute and 10 seconds
import sys
import pprint
import logging
from contextlib import contextmanager
from typing import Iterable, Optional, List
......@@ -255,9 +254,9 @@ class InputMergeActor(AbstractActor):
class EwoksWorkflow(Workflow):
def __init__(self, ewoksgraph: TaskGraph, ppf_log_level=logging.WARNING):
def __init__(self, ewoksgraph: TaskGraph):
name = repr(ewoksgraph)
super().__init__(name, level=ppf_log_level)
super().__init__(name)
# When triggering a task, the output dict of the previous task
# is merged with the input dict of the current task.
......@@ -568,11 +567,10 @@ 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, ppf_log_level=ppf_log_level)
ppfgraph = EwoksWorkflow(ewoksgraph)
return ppfgraph.run(**execute_options)
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment