Merge pull request #409 from radical-cybertools/fix/flux_log

Fix/flux log

src/radical/utils/flux.py

@@ -263,7 +263,7 @@ class FluxHelper(object):
 
     # --------------------------------------------------------------------------
     #
-    def __init__(self) -> None:
+    def __init__(self, uid:str = None) -> None:
         '''
         The Flux Helper c'tor takes no arguments and will initially not be
         connected to a Flux instance.  After construction, the application can
@@ -309,15 +309,16 @@ def __init__(self) -> None:
 
         self._service : Optional[_FluxService] = None
 
-        self._uri       = None
-        self._env       = None
+        if uid: self._uid = uid
+        else  : self._uid = generate_id('flux.%(item_counter)04d', ID_CUSTOM)
 
-        self._uid       = generate_id('flux.%(item_counter)04d', ID_CUSTOM)
         self._log       = Logger(self._uid,   ns='radical.utils')
         self._prof      = Profiler(self._uid, ns='radical.utils')
 
         self._lock      = mt.RLock()
 
+        self._uri       = None
+        self._env       = None
         self._exe       = None
         self._handle    = None
         self._handles   = list()  # TODO