Skip to content
GitLab
Commit 534f0605 authored by Wout De Nolf's avatar Wout De Nolf
Browse files

Merge branch 'ewokscore_api_change' into 'main' 

ewokscore API change

See merge request !23
parents 0123e1db 0907eb9d
Pipeline #66409 passed with stages
in 2 minutes and 32 seconds
Hide whitespace changes
Inline Side-by-side
ewoksdask/__init__.py
View file @ 534f0605
from .bindings import execute_graph # noqa: F401 from .bindings import execute_graph # noqa: F401
__version__ = "0.0.2-alpha.2" __version__ = "0.0.2-alpha.3"
ewoksdask/bindings.py
View file @ 534f0605
...@@ -38,7 +38,7 @@ def execute_task(execinfo, *inputs): ...@@ -38,7 +38,7 @@ def execute_task(execinfo, *inputs):
def convert_graph(ewoksgraph, **execute_options): def convert_graph(ewoksgraph, **execute_options):
daskgraph = dict() daskgraph = dict()
for target_id, node_attrs in ewoksgraph.graph.nodes.items(): for target_id, node_attrs in ewoksgraph.graph.nodes.items():
source_ids = tuple(analysis.predecessors(ewoksgraph.graph, target_id)) source_ids = tuple(analysis.node_predecessors(ewoksgraph.graph, target_id))
link_attrs = tuple( link_attrs = tuple(
ewoksgraph.graph[source_id][target_id] for source_id in source_ids ewoksgraph.graph[source_id][target_id] for source_id in source_ids
) )
......
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