Skip to content

Commit

Permalink
fixed graph test
Browse files Browse the repository at this point in the history
  • Loading branch information
awicenec committed May 13, 2022
1 parent efa85b9 commit a8844e1
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 2 deletions.
1 change: 1 addition & 0 deletions daliuge-engine/dlg/apps/bash_shell_app.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@
from ..exceptions import InvalidDropException
from ..meta import (
dlg_string_param,
dlg_dict_param,
dlg_component,
dlg_batch_input,
dlg_batch_output,
Expand Down
4 changes: 3 additions & 1 deletion daliuge-engine/dlg/droputils.py
Original file line number Diff line number Diff line change
Expand Up @@ -513,6 +513,8 @@ def serialize_applicationArgs(applicationArgs, prefix="--", separator=" "):
"""
if not isinstance(applicationArgs, dict):
logger.info("applicationArgs are not passed as a dict. Ignored!")
else:
logger.info("ApplicationArgs found %s", applicationArgs)
# construct the actual command line from all application parameters
args = []
pargs = []
Expand All @@ -538,7 +540,7 @@ def serialize_applicationArgs(applicationArgs, prefix="--", separator=" "):
else:
arg = [f"{prefix}{name}{separator}{value}".strip()]
args += arg

logger.info('Arguments of bash command: %s %s', args, pargs)
return f"{' '.join(args + pargs)}" # add positional arguments to end of args


Expand Down
1 change: 0 additions & 1 deletion daliuge-engine/test/graphs/test_graphExecution.py
Original file line number Diff line number Diff line change
Expand Up @@ -168,7 +168,6 @@ def test_pos_only_args(self):
sd = self.dm._sessions[sessionId].drops["2022-05-06T08:43:26_-2_0"]
fd = self.dm._sessions[sessionId].drops["2022-05-06T08:43:26_-1_0"]
with droputils.DROPWaiterCtx(self, fd, 3):
sd.write("''".encode())
sd.setCompleted()

#logger.debug(f'PyfuncAPPDrop signature: {dir(fd)}')
Expand Down

0 comments on commit a8844e1

Please sign in to comment.