@@ -138,14 +138,20 @@ def log_nodes_cb(node, status):
138
138
import logging
139
139
import json
140
140
141
+ # Address nested case
142
+ if isinstance (node .result .runtime , (list ,)):
143
+ resrunlist = node .result .runtime [0 ]
144
+ except :
145
+ resrunlist = node .result .runtime
146
+
141
147
status_dict = {
142
148
'name' : node .name ,
143
149
'id' : node ._id ,
144
- 'start' : getattr (node . result . runtime , 'startTime' ),
145
- 'finish' : getattr (node . result . runtime , 'endTime' ),
146
- 'duration' : getattr (node . result . runtime , 'duration' ),
147
- 'runtime_threads' : getattr (node . result . runtime , 'cpu_percent' , 'N/A' ),
148
- 'runtime_memory_gb' : getattr (node . result . runtime , 'mem_peak_gb' ,
150
+ 'start' : getattr (resrunlist , 'startTime' ),
151
+ 'finish' : getattr (resrunlist , 'endTime' ),
152
+ 'duration' : getattr (resrunlist , 'duration' ),
153
+ 'runtime_threads' : getattr (resrunlist , 'cpu_percent' , 'N/A' ),
154
+ 'runtime_memory_gb' : getattr (resrunlist , 'mem_peak_gb' ,
149
155
'N/A' ),
150
156
'estimated_memory_gb' : node .mem_gb ,
151
157
'num_threads' : node .n_procs ,
@@ -155,8 +161,7 @@ def log_nodes_cb(node, status):
155
161
status_dict ['error' ] = True
156
162
157
163
# Dump string to log
158
- logging .getLogger ('callback' ).debug (json .dumps (status_dict ))
159
-
164
+ logging .getLogger ('callback' ).debug (json .dumps (status_dict , allow_nan = True ))
160
165
161
166
# Get total system RAM
162
167
def get_system_total_memory_gb ():
0 commit comments