Updating constants

setup.py

@@ -6,7 +6,7 @@
 
 
 setup(name='provlake',
-      version='0.1.4',
+      version='0.1.5',
       description='A Python lib to capture multiworkflow provenance data from Python Scripts',
       url='http://ibm.biz/provlake',
       author='IBM Research',

src/provlake/__init__.py

@@ -26,18 +26,13 @@ def _build_managed_persister(
             db_name: str,
             wf_exec_id=None
     ) -> ManagedPersister:
-
         should_send_to_service = False
         if service_url is not None:
             should_send_to_service = True
 
         if not bag_size:
             bag_size = int(os.getenv("PROV_BAG_SIZE", 1))
 
-        #self.last_task_id = 0
-        #task_id = str(self.last_task_id) + "_" + str(id(self)) if self.cores > 1 else str(self.last_task_id)
-        #self.tasks = dict()
-
         if not should_send_to_service:
             assert should_send_to_file is True, "If you are using ProvLake in offline mode, " \
                                                "you need to log prov data to file. Check your 'should_send_to_file' and " \

src/provlake/utils/constants.py

@@ -111,24 +111,24 @@ def get_dte_id(wfe_id, dt_name: str, prov_task: dict):
 
     @staticmethod
     def get_wfe_ctx_id(wfe_id):
-        return wfe_id+"_ctx"
+        return wfe_id+"_wfe_ctx"
 
     @staticmethod
     def get_cce_ctx_id(cce_id):
-        return cce_id + "_ctx"
+        return cce_id + "_cce_ctx"
 
     @staticmethod
     def get_cci_ctx_id(cci_id):
-        return cci_id + "_ctx"
+        return cci_id + "_cci_ctx"
 
     @staticmethod
     def get_wfe_instantiations_ctx_id(wfe_id):
-        return wfe_id + "_instantiation"
+        return wfe_id + "_wfe_instantiation_ctx"
 
     @staticmethod
     def get_cce_instantiations_ctx_id(cce_id):
-        return cce_id + "_instantiation"
+        return cce_id + "_cce_instantiation_ctx"
 
     @staticmethod
     def get_cci_instantiations_ctx_id(cci_id):
-        return cci_id + "_instantiation"
+        return cci_id + "_cci_instantiation_ctx"