change plasma_link to plasma_path

ICRAR · May 27, 2021 · d59a93a · d59a93a
1 parent 6d84263
commit d59a93a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/daliuge-engine/dlg/drop.py b/daliuge-engine/dlg/drop.py
@@ -1732,7 +1732,7 @@ class PlasmaDROP(AbstractDROP):
     A DROP that points to data stored in a Plasma Store
     '''
     object_id = dlg_string_param('object_id', None)
-    plasma_link = dlg_string_param('plasma_link', '/tmp/plasma')
+    plasma_path = dlg_string_param('plasma_path', '/tmp/plasma')
 
     def initialize(self, **kwargs):
         object_id = self.uid
@@ -1742,7 +1742,7 @@ def initialize(self, **kwargs):
            self.object_id = object_id
 
     def getIO(self):
-        return PlasmaIO(plasma.ObjectID(self.object_id), self.plasma_link)
+        return PlasmaIO(plasma.ObjectID(self.object_id), self.plasma_path)
 
     @property
     def dataURL(self):

diff --git a/daliuge-engine/dlg/io.py b/daliuge-engine/dlg/io.py
@@ -422,13 +422,13 @@ def IOForURL(url):
 
 class PlasmaIO(DataIO):
 
-    def __init__(self, object_id, plasma_link='/tmp/plasma'):
+    def __init__(self, object_id, plasma_path='/tmp/plasma'):
         super(PlasmaIO, self).__init__()
-        self._plasma_link = plasma_link
+        self._plasma_path = plasma_path
         self._object_id = object_id
 
     def _open(self, **kwargs):
-        return plasma.connect(self._plasma_link)
+        return plasma.connect(self._plasma_path)
 
     def _close(self, **kwargs):
         pass