expose seal method

ICRAR · Aug 17, 2021 · 1dca409 · 1dca409
1 parent 176030d
commit 1dca409
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/daliuge-engine/dlg/apps/plasmaflight.py b/daliuge-engine/dlg/apps/plasmaflight.py
@@ -60,12 +60,15 @@ def get_flight(self, object_id: plasma.ObjectID, location: Optional[str]) -> paf
         else:
             raise Exception("Location required")
 
-    def put(self, data: memoryview, object_id: plasma.ObjectID):
-        self.plasma_client.put_raw_buffer(data, object_id)
-
     def create(self, object_id: plasma.ObjectID, size: int):
         return self.plasma_client.create(object_id, size)
 
+    def seal(self, object_id: plasma.ObjectID):
+        self.plasma_client.seal(object_id)
+
+    def put(self, data: memoryview, object_id: plasma.ObjectID):
+        self.plasma_client.put_raw_buffer(data, object_id)
+
     def get(self, object_id: plasma.ObjectID, owner: Optional[str] = None) -> memoryview:
         logger.debug(f"PlasmaFlightClient Get {object_id}")
         if self.plasma_client.contains(object_id):