diff --git a/trustgraph-flow/trustgraph/cores/service.py b/trustgraph-flow/trustgraph/cores/service.py index 18154fc5..b8cc5f9e 100755 --- a/trustgraph-flow/trustgraph/cores/service.py +++ b/trustgraph-flow/trustgraph/cores/service.py @@ -124,12 +124,13 @@ class Processor(AsyncProcessor): logger.info(f"Configuration version: {version}") - if "flows" in config: - + if "flow" in config: self.flows = { k: json.loads(v) - for k, v in config["flows"].items() + for k, v in config["flow"].items() } + else: + self.flows = {} logger.debug(f"Flows: {self.flows}")