Skip to content

Commit

Permalink
work in progress to fix the main merge
Browse files Browse the repository at this point in the history
  • Loading branch information
jjkoehorst committed Aug 17, 2023
1 parent 87946a3 commit 420dd1c
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 2 deletions.
6 changes: 4 additions & 2 deletions cwltool/cwlprov/provenance_profile.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@
from prov.model import PROV, PROV_LABEL, PROV_TYPE, PROV_VALUE, ProvDocument, ProvEntity
from schema_salad.sourceline import SourceLine

import cwltool.workflow

from ..errors import WorkflowException
from ..job import CommandLineJob, JobBase
from ..loghandler import _logger
Expand Down Expand Up @@ -55,7 +57,7 @@
from .ro import ResearchObject


def copy_job_order(job: Union[Process, JobsType], job_order_object: CWLObjectType) -> CWLObjectType:
def copy_job_order(job: Union[Process, JobsType], job_order_object: CWLObjectType, process) -> CWLObjectType:
"""Create copy of job object for provenance."""
if not isinstance(job, WorkflowJob):
# direct command line tool execution
Expand Down Expand Up @@ -265,7 +267,7 @@ def evaluate(
if not hasattr(process, "steps"):
# record provenance of independent commandline tool executions
self.prospective_prov(job)
customised_job = copy_job_order(job, job_order_object)
customised_job = copy_job_order(job, job_order_object, process)

Check warning on line 270 in cwltool/cwlprov/provenance_profile.py

View check run for this annotation

Codecov / codecov/patch

cwltool/cwlprov/provenance_profile.py#L270

Added line #L270 was not covered by tests
self.used_artefacts(customised_job, self.workflow_run_uri)
create_job(research_obj, customised_job)
elif hasattr(job, "workflow"):
Expand Down
3 changes: 3 additions & 0 deletions cwltool/cwlprov/ro.py
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,9 @@ def __init__(
self._initialize()
_logger.debug("[provenance] Temporary research object: %s", self.folder)

# No data option
self.no_data = False

def self_check(self) -> None:
"""Raise ValueError if this RO is closed."""
if self.closed:
Expand Down

0 comments on commit 420dd1c

Please sign in to comment.