Ignore exceptions while fetching workflow status

gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobLauncher.java

@@ -137,8 +137,19 @@ protected void executeCancellation() {
           .build();
       DescribeWorkflowExecutionResponse response = workflowServiceStubs.blockingStub().describeWorkflowExecution(request);
 
+      WorkflowExecutionStatus status;
+      try {
+        status = response.getWorkflowExecutionInfo().getStatus();
+      }
+      catch (Exception e) {
+        log.warn("Exception occurred while getting status of the workflow " + this.workflowId
+            + ". We would still attempt the cancellation", e);
+        workflowStub.cancel();
+        log.info("Temporal workflow {} cancelled successfully", this.workflowId);
+        return;
+      }
+
       // Check if the workflow is not finished
-      WorkflowExecutionStatus status = response.getWorkflowExecutionInfo().getStatus();
       if (status != WorkflowExecutionStatus.WORKFLOW_EXECUTION_STATUS_COMPLETED &&
           status != WorkflowExecutionStatus.WORKFLOW_EXECUTION_STATUS_FAILED &&
           status != WorkflowExecutionStatus.WORKFLOW_EXECUTION_STATUS_CANCELED &&

gobblin-temporal/src/test/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobLauncherTest.java

@@ -167,4 +167,16 @@ public void testCancelWorkflowIfRunning() throws Exception {
 
     verify(mockStub, times(1)).cancel();
   }
+
+  @Test
+  public void testCancelWorkflowFetchStatusThrowsException() throws Exception {
+    // Mock the get workflow status to throw an exception
+    Mockito.doThrow(new RuntimeException("Some exception occurred")).when(mockExecutionInfo).getStatus();
+
+    jobLauncher.submitJob(null);
+
+    jobLauncher.executeCancellation();
+
+    verify(mockStub, times(1)).cancel();
+  }
 }