Skip to content

Commit

Permalink
concise syntax
Browse files Browse the repository at this point in the history
Signed-off-by: Simon Brugman <[email protected]>
  • Loading branch information
sbrugman committed Oct 9, 2023
1 parent b146740 commit 274837f
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions kedro-airflow/kedro_airflow/plugin.py
Original file line number Diff line number Diff line change
Expand Up @@ -173,11 +173,9 @@ def create( # noqa: PLR0913

# group memory nodes
if group_in_memory:
catalog = context.catalog
nodes, dependencies = group_memory_nodes(catalog, pipeline)
nodes, dependencies = group_memory_nodes(context.catalog, pipeline)
else:
nodes = pipeline.nodes
nodes = {node.name: [node] for node in nodes}
nodes = {node.name: [node] for node in pipeline.nodes}

dependencies = defaultdict(list)
for node, parent_nodes in pipeline.node_dependencies.items():
Expand Down

0 comments on commit 274837f

Please sign in to comment.