@@ -117,8 +117,7 @@ public PreComputeResponse runTeePreCompute(TaskDescription taskDescription, Work
117117 .ofGigabytes (workerConfigService .getTeeComputeMaxHeapSizeGb ())
118118 .toBytes ();
119119 if (enclaveConfig .getHeapSize () > teeComputeMaxHeapSize ) {
120- log .error ("Enclave configuration should define a proper heap " +
121- "size [chainTaskId:{}, heapSize:{}, maxHeapSize:{}]" ,
120+ log .error ("Enclave configuration should define a proper heap size [chainTaskId:{}, heapSize:{}, maxHeapSize:{}]" ,
122121 chainTaskId , enclaveConfig .getHeapSize (), teeComputeMaxHeapSize );
123122 preComputeResponseBuilder .exitCauses (List .of (PRE_COMPUTE_INVALID_ENCLAVE_HEAP_CONFIGURATION ));
124123 return preComputeResponseBuilder .build ();
@@ -140,8 +139,8 @@ public PreComputeResponse runTeePreCompute(TaskDescription taskDescription, Work
140139
141140 // run TEE pre-compute container if needed
142141 if (taskDescription .requiresPreCompute ()) {
143- log .info ("Task contains TEE input data [chainTaskId:{}, containsDataset:{}, containsInputFiles:{}]" ,
144- chainTaskId , taskDescription .containsDataset (), taskDescription .containsInputFiles ());
142+ log .info ("Task contains TEE input data [chainTaskId:{}, containsDataset:{}, containsInputFiles:{}, isBulkRequest:{} ]" ,
143+ chainTaskId , taskDescription .containsDataset (), taskDescription .containsInputFiles (), taskDescription . isBulkRequest () );
145144 final List <ReplicateStatusCause > exitCauses = downloadDatasetAndFiles (taskDescription , secureSession );
146145 preComputeResponseBuilder .exitCauses (exitCauses );
147146 }
@@ -150,12 +149,12 @@ public PreComputeResponse runTeePreCompute(TaskDescription taskDescription, Work
150149 }
151150
152151 private List <ReplicateStatusCause > downloadDatasetAndFiles (
153- TaskDescription taskDescription ,
154- TeeSessionGenerationResponse secureSession ) {
152+ final TaskDescription taskDescription ,
153+ final TeeSessionGenerationResponse secureSession ) {
155154 try {
156- Integer exitCode = prepareTeeInputData (taskDescription , secureSession );
155+ final Integer exitCode = prepareTeeInputData (taskDescription , secureSession );
157156 if (exitCode == null || exitCode != 0 ) {
158- String chainTaskId = taskDescription .getChainTaskId ();
157+ final String chainTaskId = taskDescription .getChainTaskId ();
159158 final List <ReplicateStatusCause > exitCauses = getExitCauses (chainTaskId , exitCode );
160159 log .error ("Failed to prepare TEE input data [chainTaskId:{}, exitCode:{}, exitCauses:{}]" ,
161160 chainTaskId , exitCode , exitCauses );
0 commit comments