[fix](trainer/bridge): connected_at and terminated_at error (#834)

* fix(trainer/bridge): connected_at and terminated_at error * fix: log_level
bytedance · Jun 1, 2021 · 930a4cf · 930a4cf
1 parent 92055f8
commit 930a4cf
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/fedlearner/common/fl_logging.py b/fedlearner/common/fl_logging.py
@@ -33,7 +33,7 @@
 }
 
 def _get_level_from_env():
-    level_name = os.getenv("FL_LOG_LEVEL")
+    level_name = os.getenv("FL_LOG_LEVEL", "").lower()
     if level_name in _name_to_level:
         return _name_to_level[level_name]
 

diff --git a/fedlearner/trainer/bridge.py b/fedlearner/trainer/bridge.py
@@ -126,11 +126,11 @@ def worker_rank(self):
 
     @property
     def connected_at(self):
-        return self._channel._connected_at
+        return self._channel.connected_at
 
     @property
     def terminated_at(self):
-        return self._channel._closed_at
+        return self._channel.closed_at
 
     def _check_iteration_timeout(self):
         with self._condition:

diff --git a/web_console/components/CommonTicket.jsx b/web_console/components/CommonTicket.jsx
@@ -357,7 +357,7 @@ export default function TicketList({
     const insert2Env = filterArrayValue([
       { name: 'DATA_SOURCE', getValue: data => data.datasource },
       jobType === JOB_TYPE.nn_model
-        ? { name: 'CODE_KEY', getValue: data => data.code_key, writeTo: ['Worker'] }
+        ? { name: 'CODE_KEY', getValue: data => data.code_key, writeTo: ['Master', 'Worker'] }
         : undefined
     ])
     rewriteEnvs(draft, data, insert2Env)