diff --git a/cws-engine-service/src/main/java/jpl/cws/engine/CwsEngineProcessApplication.java b/cws-engine-service/src/main/java/jpl/cws/engine/CwsEngineProcessApplication.java index dcea45bc..2dab8c8d 100644 --- a/cws-engine-service/src/main/java/jpl/cws/engine/CwsEngineProcessApplication.java +++ b/cws-engine-service/src/main/java/jpl/cws/engine/CwsEngineProcessApplication.java @@ -320,11 +320,11 @@ public void notify(final DelegateExecution execution) throws Exception { log.error("procDefKey unable to be determined!"); } log.trace("sendProcEventTopicMessageWithRetries"); - - //String startedOnWorkerId = execution.getVariable("startedOnWorkerId").toString(); - //if (startedOnWorkerId != null && !startedOnWorkerId.equals(workerId)) { - // log.trace("Started on worker != ended on worker"); - //} + + String startedOnWorkerId = execution.getVariable("startedOnWorkerId").toString(); + if (startedOnWorkerId != null && !startedOnWorkerId.equals(workerId)) { + log.debug("PROCESS '" + procDefKey + "' - Started on worker[" + startedOnWorkerId + "] != ended[" + workerId + "] on worker"); + } // FIXME: UUID might not be right if (execution.getVariable("uuid") != null) { processService.sendProcEventTopicMessageWithRetries( @@ -333,6 +333,8 @@ public void notify(final DelegateExecution execution) throws Exception { procDefKey, repositoryService.getProcessDefinition(execution.getProcessDefinitionId()).getDeploymentId(), "processEndEventDetected"); + } else { + log.warn("WARNING: UUID of an instance of procDef '" + procDefKey + "' cannot be found. "); } } } diff --git a/cws-engine-service/src/main/java/jpl/cws/engine/CwsExternalTaskService.java b/cws-engine-service/src/main/java/jpl/cws/engine/CwsExternalTaskService.java index 5916cbd8..08122676 100644 --- a/cws-engine-service/src/main/java/jpl/cws/engine/CwsExternalTaskService.java +++ b/cws-engine-service/src/main/java/jpl/cws/engine/CwsExternalTaskService.java @@ -89,7 +89,7 @@ public boolean canAcceptMoreWork() { return locked < numCores; } catch (Exception e) { - // We don't really care if this fails + log.error("Exception canAcceptMoreWork: ", e); return false; } }