diff --git a/cwltool/workflow.py b/cwltool/workflow.py index 7c6dddd67..2e1ee1193 100644 --- a/cwltool/workflow.py +++ b/cwltool/workflow.py @@ -205,7 +205,6 @@ def __init__(self, workflow, **kwargs): self.workflow = workflow self.tool = workflow.tool self.steps = [WorkflowJobStep(s) for s in workflow.steps] - self.id = workflow.tool["id"] self.state = None # type: Dict[Text, WorkflowStateItem] self.processStatus = None # type: Text if "outdir" in kwargs: @@ -216,9 +215,9 @@ def __init__(self, workflow, **kwargs): # tmp_outdir_prefix defaults to tmp, so this is unlikely to be used self.outdir = tempfile.mkdtemp() - self.name = uniquename(u"workflow %s" % kwargs.get("name", shortname(self.workflow.tool["id"]))) + self.name = uniquename(u"workflow %s" % kwargs.get("name", shortname(self.workflow.tool.get("id", "embedded")))) - _logger.debug(u"[%s] initialized step from %s", self.name, self.tool["id"]) + _logger.debug(u"[%s] initialized from %s", self.name, self.tool.get("id", "workflow embedded in %s" % kwargs.get("part_of"))) def receive_output(self, step, outputparms, jobout, processStatus): # type: (WorkflowJobStep, List[Dict[Text,Text]], Dict[Text,Text], Text) -> None