fix get_privileged_data_layer_client with dropping keyspace

Author: Istemi Ekin Akkus

FunctionWorker/python/MicroFunctionsAPI.py

@@ -81,14 +81,12 @@ def __init__(self, uid, sid, wid, funcstatename, key, publication_utils, is_sess
 
         #self._logger.debug("[MicroFunctionsAPI] init done.")
 
-    def get_privileged_data_layer_client(self, suid=None, keyspace=None, init_tables=False, drop_keyspace=False):
+    def get_privileged_data_layer_client(self, suid=None, sid=None, init_tables=False, drop_keyspace=False):
         if self._is_privileged:
             if suid is not None:
                 return DataLayerClient(locality=1, suid=suid, connect=self._datalayer, init_tables=init_tables, drop_keyspace=drop_keyspace)
-            elif keyspace is not None:
-                dlc = DataLayerClient(locality=1, for_mfn=True, connect=self._datalayer)
-                dlc.keyspace = keyspace
-                return dlc
+            elif sid is not None:
+                return DataLayerClient(locality=1, for_mfn=True, sid=sid, connect=self._datalayer, drop_keyspace=drop_keyspace)
         return None
 
     def update_metadata(self, metadata_name, metadata_value, is_privileged_metadata=False):

JavaRequestHandler/src/main/java/org/microfunctions/mfnapi/MicroFunctionsAPI.java

@@ -214,7 +214,7 @@ def get_data_to_be_deleted(self, is_private=False):
 
     ===================
     
-    def get_privileged_data_layer_client(self, suid=None, keyspace=None, tablename=None, maptablename=None, settablename=None, countertablename=None, init_tables=False):
+    def get_privileged_data_layer_client(self, suid=None, sid=None, init_tables=False, drop_keyspace=False):
     
     */
 

ManagementService/python/deleteAccount.py

@@ -42,7 +42,7 @@ def delete_single_workflow(email, wid, sapi):
     # 1. workflow private keyspace
     # 2. mfn metadata store keyspace
     # just drop the keyspace
-    dlc = sapi.get_privileged_data_layer_client(keyspace="sbox_" + wid, drop_keyspace=True)
+    dlc = sapi.get_privileged_data_layer_client(sid=wid, drop_keyspace=True)
     dlc.shutdown()
 
     # TODO: local data layer entries for each workflow