theory silas diss

projects/IMDD_base_system/submit_handle.m

@@ -58,11 +58,14 @@ if options.parallel
     updateWaitbarFutures = afterEach(results, updateWaitbar, 0);
     afterAll(updateWaitbarFutures, @(~) delete(h), 0);
 
-    %%% 7) Fetch final results after all computations
-    fetchOutputs(results);
-
-    for ridx = 1:length(results)
-        wh.addValueToStorageByLinIdx(results(ridx).OutputArguments{1}, 'ber', ridx);
+    %%% 7) Fetch final results iteratively as they finish
+    for i = 1:length(results)
+        try
+            [ridx, result] = fetchNext(results);
+            wh.addValueToStorageByLinIdx(result, 'ber', ridx);
+        catch ME
+            fprintf('A job failed or could not be fetched. Error: %s\n', ME.message);
+        end
     end
 end