Skip to content

Commit

Permalink
Minor log change
Browse files Browse the repository at this point in the history
  • Loading branch information
pditommaso committed Mar 15, 2020
1 parent 0a1ec9a commit 130a963
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -62,31 +62,31 @@ class WorkflowStatsObserver implements TraceObserver {

@Override
void onProcessPending(TaskHandler handler, TraceRecord trace){
log.trace "== event pending pid=${handler.getTask().processor.id}"
log.trace "== event pending pid=${handler.getTask().processor.id}; status=$handler.status"
agent.send { data.markPending(handler.getTask().processor) }
}

@Override
void onProcessSubmit(TaskHandler handler, TraceRecord trace){
log.trace "== event submit pid=${handler.getTask().processor.id}"
log.trace "== event submit pid=${handler.getTask().processor.id}; status=$handler.status"
agent.send { data.markSubmitted(handler.getTask()) }
}

@Override
void onProcessStart(TaskHandler handler, TraceRecord trace){
log.trace "== event start pid=${handler.getTask().processor.id}"
log.trace "== event start pid=${handler.getTask().processor.id}; status=$handler.status"
agent.send { data.markRunning(handler.getTask()) }
}

@Override
void onProcessComplete(TaskHandler handler, TraceRecord trace) {
log.trace "== event complete pid=${handler.getTask().processor.id}"
log.trace "== event complete pid=${handler.getTask().processor.id}; status=$handler.status"
agent.send { data.markCompleted(handler.getTask(), trace) }
}

@Override
void onProcessCached(TaskHandler handler, TraceRecord trace){
log.trace "== event cached pid=${handler.getTask().processor.id}"
log.trace "== event cached pid=${handler.getTask().processor.id}; status=$handler.status"
agent.send { data.markCached(handler.getTask(), trace) }
}

Expand Down

0 comments on commit 130a963

Please sign in to comment.