Worker status fix

Description

Fixes worker status issues.

Changes

Worker status is properly reset once replies are received.

Test and Review

To be filled in by the reviewers

• All of the methods are commented to expectation

• The methods are tested to satisfaction

• There are no unnecessary files present in the MR

• The continuous integration has no problems with the MR

• The MR is filled in as requested (including labels, milestones, and reviewers)

• The documentation is up-to-date

• All nullable parameters are marked as such

core/src/main/java/nl/tudelft/ewi/auta/core/communication/MessageReceiver.java

@@ -226,6 +226,7 @@ public class MessageReceiver {
             submission.getPipelineLog().setAnalysisDone(Instant.now());
             this.submissionRepository.save(submission);
 
+            worker.setCurrentJob(null);
             this.pool.dismiss(worker);
 
             this.threads.run(() -> this.resultsProcessor.process(
@@ -238,7 +239,6 @@ public class MessageReceiver {
                     )
             ));
 
-            worker.setCurrentJob(null);
             logger.info("Job {} finished by {}", msg.getId(), worker);
         }
     }
@@ -285,6 +285,7 @@ public class MessageReceiver {
                     this.submissionRepository.save(submission);
 
                     this.resultsProcessor.process(fakeResults);
+                    worker.setCurrentJob(null);
                     this.pool.dismiss(worker);
                 } else {
                     logger.warn("Idle worker {} reported exception {}", worker, message.getData());