File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -119,16 +119,15 @@ def filter(self) -> list:
119119 if process_pool [i ] and not process_pool [i ].is_alive ():
120120 process_pool [i ].join ()
121121 process_pool [i ] = None
122+ if not queue .empty ():
123+ self .__drain_processing_queue (queue , converted_error_traces , memory_usage_all )
122124 if not process_pool [i ]:
123125 process_pool [i ] = multiprocessing .Process (target = self .__process_trace ,
124126 name = error_trace_file ,
125127 args = (error_trace_file ,
126128 queue ))
127129 process_pool [i ].start ()
128130 raise NestedLoop
129- else :
130- if not queue .empty ():
131- self .__drain_processing_queue (queue , converted_error_traces , memory_usage_all )
132131 time .sleep (BUSY_WAITING_INTERVAL )
133132 except NestedLoop :
134133 pass
@@ -144,7 +143,7 @@ def filter(self) -> list:
144143 # Need to sort traces for deterministic results.
145144 # Moreover, first traces are usually more "simpler".
146145 sorted_traces = {}
147- for trace in converted_error_traces . keys () :
146+ for trace in converted_error_traces :
148147 identifier = re .search (rf'witness(.*){ Extension .GRAPHML } ' , trace ).group (1 )
149148 key = identifier
150149 if identifier .isdigit ():
You can’t perform that action at this time.
0 commit comments