Skip to content

Commit

Permalink
Fix passing of plasma socket link to plasma data component
Browse files Browse the repository at this point in the history
  • Loading branch information
awicenec committed May 27, 2021
1 parent 80521e9 commit 6d84263
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions daliuge-engine/dlg/apps/plasma.py
Original file line number Diff line number Diff line change
Expand Up @@ -64,14 +64,14 @@ class MSStreamingPlasmaConsumer(AppDROP):
[dlg_batch_output('binary/*', [])],
[dlg_streaming_input('binary/*')])

plasma_path = dlg_string_param('plasma_path', '')
plasma_path = dlg_string_param('plasma_path', '/tmp/plasma')

def initialize(self, **kwargs):
self.config = {
'reception': {
"consumer": "plasma_writer",
"test_entry": 5,
"plasma_path": '/tmp/plasma'
"plasma_path": self.plasma_path
}
}
self.thread = None
Expand Down
2 changes: 1 addition & 1 deletion daliuge-engine/run_engine.sh
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ case "$1" in
"dev")
export VCS_TAG=`git rev-parse --abbrev-ref HEAD | tr '[:upper:]' '[:lower:]'`
echo "Running Engine development version in foreground..."
DOCKER_OPTS+="-v ${PWD}/dlg/manager:/home/ray/dlg/lib/python3.8/site-packages/dlg/manager"
DOCKER_OPTS+="-v ${PWD}/dlg/manager:/root/dlg/lib/python3.8/site-packages/dlg/manager"
echo "docker run -ti ${DOCKER_OPTS} icrar/daliuge-engine:${VCS_TAG}"
docker run -ti ${DOCKER_OPTS} icrar/daliuge-engine:${VCS_TAG} bash
exit 1;;
Expand Down

0 comments on commit 6d84263

Please sign in to comment.