extend logging

MGX-metagenomics · Oct 5, 2023 · eadfe97 · eadfe97
1 parent 0cf450e
commit eadfe97
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git a/MGX-dispatcher-api/src/main/java/de/cebitec/mgx/dispatcher/api/JobI.java b/MGX-dispatcher-api/src/main/java/de/cebitec/mgx/dispatcher/api/JobI.java
@@ -12,9 +12,6 @@ public abstract class JobI implements Runnable {
 
     public static final int DEFAULT_PRIORITY = 500;
 
-//    public JobI(Dispatcher d) {
-//        this(d, DEFAULT_PRIORITY);
-//    }
     public JobI(DispatcherI d, long projJobId, String projName, int prio) {
         dispatcher = d;
         projectJobId = projJobId;

diff --git a/MGX-dispatcher-mgx/src/main/java/de/cebitec/mgx/dispatcher/mgx/MGX2CWLJob.java b/MGX-dispatcher-mgx/src/main/java/de/cebitec/mgx/dispatcher/mgx/MGX2CWLJob.java
@@ -217,6 +217,7 @@ private void setFinishDate() throws JobException {
 
     @Override
     public synchronized void setState(JobState state) throws JobException {
+        Logger.getLogger(MGX2ConveyorJob.class.getName()).log(Level.INFO, "Setting MGX2 CWL job {0} to state {1}", new Object[]{getProjectJobID(), state});
         //Logger.getLogger(MGXJob.class.getName()).log(Level.INFO, "{0}/{1}: state change {2} to {3}", new Object[]{projectName, mgxJobId, getState(), state});
         String sql = "UPDATE job SET job_state=? WHERE id=? RETURNING job_state";
         try (Connection conn = getProjectConnection()) {

diff --git a/MGX-dispatcher-mgx/src/main/java/de/cebitec/mgx/dispatcher/mgx/MGX2ConveyorJob.java b/MGX-dispatcher-mgx/src/main/java/de/cebitec/mgx/dispatcher/mgx/MGX2ConveyorJob.java
@@ -254,7 +254,7 @@ private void setFinishDate() throws JobException {
 
     @Override
     public synchronized void setState(JobState state) throws JobException {
-        Logger.getLogger(MGX2ConveyorJob.class.getName()).log(Level.INFO, "Setting job {0} to state {1}", new Object[]{getProjectJobID(), state});
+        Logger.getLogger(MGX2ConveyorJob.class.getName()).log(Level.INFO, "Setting MGX2 Conveyor job {0} to state {1}", new Object[]{getProjectJobID(), state});
         //Logger.getLogger(MGXJob.class.getName()).log(Level.INFO, "{0}/{1}: state change {2} to {3}", new Object[]{projectName, mgxJobId, getState(), state});
         String sql = "UPDATE job SET job_state=? WHERE id=? RETURNING job_state";
         try ( Connection conn = getProjectConnection()) {