cwltool.subgraph

Attributes

UP
DOWN
INPUT
OUTPUT
STEP

Classes

Node

Functions

subgraph_visit(current, nodes, visited, direction)
declare_node(nodes, nodeid, tp)	Record the given nodeid in the graph.
find_step(steps, stepid, loading_context)	Find the step (raw dictionary and WorkflowStep) for a given step id.
get_subgraph(roots, tool, loading_context)	Extract the subgraph for the given roots.
get_step(tool, step_id, loading_context)	Extract a single WorkflowStep for the given step_id.
get_process(tool, step_id, loading_context)	Find the underlying Process for a given Workflow step id.

Module Contents

class cwltool.subgraph.Node

Bases: tuple

up

down

type

cwltool.subgraph.UP = 'up'

cwltool.subgraph.DOWN = 'down'

cwltool.subgraph.INPUT = 'input'

cwltool.subgraph.OUTPUT = 'output'

cwltool.subgraph.STEP = 'step'

cwltool.subgraph.subgraph_visit(current, nodes, visited, direction)

Parameters:

• current (str)

• nodes (collections.abc.MutableMapping[str, Node])

• visited (set[str])

• direction (str)

Return type:

None

cwltool.subgraph.declare_node(nodes, nodeid, tp)

Record the given nodeid in the graph.

If the nodeid is already present, but its type is unset, set it. :returns: The Node tuple (even if already present in the graph).

Parameters:

• nodes (dict[str, Node])

• nodeid (str)

• tp (Optional[str])

Return type:

Node

cwltool.subgraph.find_step(steps, stepid, loading_context)

Find the step (raw dictionary and WorkflowStep) for a given step id.

Parameters:

• steps (list[cwltool.workflow.WorkflowStep])

• stepid (str)

• loading_context (cwltool.context.LoadingContext)

Return type:

tuple[Optional[cwltool.utils.CWLObjectType], Optional[cwltool.workflow.WorkflowStep]]

cwltool.subgraph.get_subgraph(roots, tool, loading_context)

Extract the subgraph for the given roots.

Parameters:

• roots (collections.abc.MutableSequence[str])

• tool (cwltool.workflow.Workflow)

• loading_context (cwltool.context.LoadingContext)

Return type:

ruamel.yaml.comments.CommentedMap

cwltool.subgraph.get_step(tool, step_id, loading_context)

Extract a single WorkflowStep for the given step_id.

Parameters:

• tool (cwltool.workflow.Workflow)

• step_id (str)

• loading_context (cwltool.context.LoadingContext)

Return type:

ruamel.yaml.comments.CommentedMap

cwltool.subgraph.get_process(tool, step_id, loading_context)

Find the underlying Process for a given Workflow step id.

Parameters:

• tool (cwltool.workflow.Workflow)

• step_id (str)

• loading_context (cwltool.context.LoadingContext)

Return type:

tuple[Any, cwltool.workflow.WorkflowStep]