Skip to content

Commit

Permalink
publisher changes
Browse files Browse the repository at this point in the history
  • Loading branch information
lukasheinrich committed Nov 21, 2017
1 parent e058a30 commit 1a9e82b
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 1 deletion.
2 changes: 1 addition & 1 deletion packtivity/asyncbackends.py
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ def submit(self, spec, parameters, state, metadata = None):
spec = spec,
parameters = parameters,
state = state,
metadata = metadata,
metadata = metadata or {'name': 'packtivity'},
config = self.config
)
return self.submit_callable(nullary)
Expand Down
6 changes: 6 additions & 0 deletions packtivity/handlers/publisher_handlers.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,9 @@ def interpolated_pub_handler(publisher,parameters,state):
globbed = glob2.glob(globexpr)
if globbed:
resultval = globbed
else:
#if it's a string and the full path exists replace relative path
resultval = globexpr
path.set(result,resultval)
return result

Expand Down Expand Up @@ -66,6 +69,9 @@ def fromparjq_pub(publisher,parameters,state):
globbed = glob2.glob(globexpr)
if globbed:
value = globbed
else:
#if it's a string and the full path exists replace relative path
value = globexpr
path.set(result,value)
return result

Expand Down

0 comments on commit 1a9e82b

Please sign in to comment.