Skip to content

Commit

Permalink
Merge 069e493 into 571ef08
Browse files Browse the repository at this point in the history
  • Loading branch information
dprelipcean committed Aug 14, 2019
2 parents 571ef08 + 069e493 commit cf93069
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 15 deletions.
10 changes: 4 additions & 6 deletions reana_workflow_engine_yadage/externalbackend.py
Expand Up @@ -14,8 +14,8 @@
import pipes

from packtivity.asyncbackends import PacktivityProxyBase
from packtivity.syncbackends import (build_job, contextualize_parameters,
packconfig, publish)
from packtivity.syncbackends import (build_job, finalize_inputs, packconfig,
publish)
from reana_commons.api_client import JobControllerAPIClient as rjc_api_client

from .config import LOGGING_MODULE, MOUNT_CVMFS
Expand Down Expand Up @@ -93,8 +93,7 @@ def prepublish(self, spec, parameters, context):

def submit(self, spec, parameters, state, metadata):
"""Submit a yadage packtivity to RJC."""
parameters = contextualize_parameters(parameters,
state)
parameters = finalize_inputs(parameters, state)
job = build_job(spec['process'], parameters, state, self.config)

if 'command' in job:
Expand Down Expand Up @@ -155,8 +154,7 @@ def submit(self, spec, parameters, state, metadata):

def result(self, resultproxy):
"""Retrieve the result of a pactivity run by RJC."""
resultproxy.pars = contextualize_parameters(resultproxy.pars,
resultproxy.state)
resultproxy.pars = finalize_inputs(resultproxy.pars, resultproxy.state)
return publish(
resultproxy.spec['publisher'],
resultproxy.pars, resultproxy.state, self.config
Expand Down
2 changes: 1 addition & 1 deletion reana_workflow_engine_yadage/version.py
Expand Up @@ -14,4 +14,4 @@

from __future__ import absolute_import, print_function

__version__ = "0.5.0"
__version__ = "0.6.0"
14 changes: 6 additions & 8 deletions setup.py
Expand Up @@ -41,20 +41,18 @@
]

install_requires = [
'adage==0.8.5',
'adage==0.10.0',
'click>=7',
'enum34>=1.1.6',
'packtivity==0.10.0',
'pyOpenSSL==17.5.0', # FIXME remove once yadage-schemas solves deps.
'jq==0.1.6',
'networkx==1.11',
'packtivity==0.14.21',
'reana-commons>=0.6.0.dev20190812,<0.7.0',
'requests==2.20.0',
'rfc3987==1.3.7', # FIXME remove once yadage-schemas solves deps.
'strict-rfc3339==0.7', # FIXME remove once yadage-schemas solves deps.
'SQLAlchemy-Utils>=0.32.18',
'SQLAlchemy>=1.1.14',
'yadage-schemas==0.7.16',
'yadage==0.13.5',
'webcolors==1.7', # FIXME remove once yadage-schemas solves deps.
'yadage==0.20.0',
'yadage-schemas==0.10.6',
]

packages = find_packages()
Expand Down

0 comments on commit cf93069

Please sign in to comment.