diff --git a/src/radical/utils/flux.py b/src/radical/utils/flux.py index edbfbc6a..92980e0b 100644 --- a/src/radical/utils/flux.py +++ b/src/radical/utils/flux.py @@ -263,7 +263,7 @@ class FluxHelper(object): # -------------------------------------------------------------------------- # - def __init__(self, name:str = None) -> 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,16 +309,16 @@ def __init__(self, name:str = None) -> 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._name = name or self._uid - self._log = Logger(self._name, ns='radical.utils') - self._prof = Profiler(self._name, ns='radical.utils') + 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