@@ -191,15 +191,15 @@ private <M extends AbstractNeuronEntity, T extends AbstractNeuronEntity> Flux<CD
191191 return Flux .fromIterable (listOfMatchesGroupedByMask )
192192 .doOnNext (groupedCDMatches -> {
193193 long startProcessingPartitionTime = System .currentTimeMillis ();
194- String maskId = groupedCDMatches .getKey (). getMipId ();
195- MDC .put ("maskId" , maskId );
194+ M mask = groupedCDMatches .getKey ();
195+ MDC .put ("maskId" , mask . getMipId () + "/" + mask . getEntityId () );
196196 List <CDMatchEntity <M , T >> cdMatches = groupedCDMatches .getItems ();
197- LOG .info ("Processing {} matches for {}" , cdMatches .size (), maskId );
197+ LOG .info ("Processing {} matches for {}/{} " , cdMatches .size (), mask . getMipId (), mask . getEntityId () );
198198 // normalize the grad scores
199199 normalizeScores (groupedCDMatches );
200- LOG .info ("Finished normalizing {} scores for {} matches in {}s- memory usage {}M out of {}M" ,
200+ LOG .info ("Finished normalizing {} scores for {}/{} matches in {}s- memory usage {}M out of {}M" ,
201201 cdMatches .size (),
202- maskId ,
202+ mask . getMipId (), mask . getEntityId () ,
203203 (System .currentTimeMillis () - startProcessingPartitionTime ) / 1000. ,
204204 (Runtime .getRuntime ().totalMemory () - Runtime .getRuntime ().freeMemory ()) / _1M + 1 , // round up
205205 (Runtime .getRuntime ().totalMemory () / _1M ));
0 commit comments