File tree Expand file tree Collapse file tree 2 files changed +6
-11
lines changed Expand file tree Collapse file tree 2 files changed +6
-11
lines changed Original file line number Diff line number Diff line change @@ -118,13 +118,6 @@ def _work_dir_changed(self, change):
118
118
""" ,
119
119
)
120
120
121
- @observe ('cluster_id' )
122
- def _cluster_id_changed (self , change ):
123
- if change ['new' ]:
124
- self .name = '{}-{}' .format (self .__class__ .name , change ['new' ])
125
- else :
126
- self .name = self .__class__ .name
127
-
128
121
loop = Instance (IOLoop )
129
122
130
123
def _loop_default (self ):
@@ -197,7 +190,7 @@ def reinit_logging(self):
197
190
pass
198
191
if self .log_to_file :
199
192
# Start logging to the new log file
200
- log_filename = self .name + u'-' + str ( os .getpid ()) + u' .log'
193
+ log_filename = f" { self .name } - { self . cluster_id } - { os .getpid ()} .log"
201
194
logfile = os .path .join (log_dir , log_filename )
202
195
if sys .__stderr__ :
203
196
print (f"Sending logs to { logfile } " , file = sys .__stderr__ )
Original file line number Diff line number Diff line change @@ -235,9 +235,11 @@ class IPController(BaseParallelApplication):
235
235
236
236
@observe ('cluster_id' )
237
237
def _cluster_id_changed (self , change ):
238
- super ()._cluster_id_changed (change )
239
- self .engine_json_file = "%s-engine.json" % self .name
240
- self .client_json_file = "%s-client.json" % self .name
238
+ base = 'ipcontroller'
239
+ if change .new :
240
+ base = f"{ base } -{ change .new } "
241
+ self .engine_json_file = f"{ base } -engine.json"
242
+ self .client_json_file = f"{ base } -client.json"
241
243
242
244
# internal
243
245
children = List ()
You can’t perform that action at this time.
0 commit comments