[gobblin] branch master updated: Send failed timer instead of success timer when job is cancelled

[lesun]

This is an automated email from the ASF dual-hosted git repository.

lesun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new d936c25  Send failed timer instead of success timer when job is 
cancelled
d936c25 is described below

commit d936c25c0757bcc37e07b4e7a968619275a639bb
Author: Jack Moseley <jmose...@linkedin.com>
AuthorDate: Mon May 24 12:06:44 2021 -0700

    Send failed timer instead of success timer when job is cancelled
---
 .../src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java
 
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java
index f7055f9..a120a36 100644
--- 
a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java
+++ 
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java
@@ -598,7 +598,7 @@ public abstract class AbstractJobLauncher implements 
JobLauncher {
               }
             });
 
-            if (jobState.getState() == JobState.RunningState.FAILED) {
+            if (jobState.getState() == JobState.RunningState.FAILED || 
jobState.getState() == JobState.RunningState.CANCELLED) {
               notifyListeners(this.jobContext, jobListener, 
TimingEvent.LauncherTimings.JOB_FAILED, new JobListenerAction() {
                 @Override
                 public void apply(JobListener jobListener, JobContext 
jobContext)