@@ -175,8 +175,8 @@ def run(self, *args, **kwargs):
175
175
176
176
# Write headers (comment trace + header row)
177
177
_header = [
178
- f" # MRIQC Resource recorder started tracking PID { self ._pid } "
179
- f" { datetime .now (tz = UTC ).strftime (' (%Y/%m/%d; %H:%M:%S)' ) } " ,
178
+ f' # MRIQC Resource recorder started tracking PID { self ._pid } '
179
+ f' { datetime .now (tz = UTC ).strftime (" (%Y/%m/%d; %H:%M:%S)" ) } ' ,
180
180
'\t ' .join (('timestamp' , * SAMPLE_ATTRS )).replace (
181
181
'memory_info' , 'mem_rss_mb\t mem_vsm_mb'
182
182
),
@@ -198,8 +198,8 @@ def run(self, *args, **kwargs):
198
198
sample2file (self ._pid , fd = _logfile , timestamp = wait_til )
199
199
except psutil .NoSuchProcess :
200
200
print (
201
- f" # MRIQC Resource recorder killed "
202
- f" { datetime .now (tz = UTC ).strftime (' (%Y/%m/%d; %H:%M:%S)' ) } " ,
201
+ f' # MRIQC Resource recorder finished '
202
+ f' { datetime .now (tz = UTC ).strftime (" (%Y/%m/%d; %H:%M:%S)" ) } ' ,
203
203
file = _logfile ,
204
204
)
205
205
_logfile .flush ()
@@ -216,6 +216,6 @@ def stop(self, *args):
216
216
self ._done .set ()
217
217
with Path (self ._logfile ).open ('a' ) as f :
218
218
f .write (
219
- f" # MRIQC Resource recorder finished "
220
- f" { datetime .now (tz = UTC ).strftime (' (%Y/%m/%d; %H:%M:%S)' ) } " ,
219
+ f' # MRIQC Resource recorder finished '
220
+ f' { datetime .now (tz = UTC ).strftime (" (%Y/%m/%d; %H:%M:%S)" ) } ' ,
221
221
)
0 commit comments