(gobblin) branch master updated: Prevent dagProcessingEngine thread termination by handling exceptions gracefully (#4105)

[vivekrai]

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

vivekrai 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 a37a2411fc Prevent dagProcessingEngine thread termination by handling 
exceptions gracefully (#4105)
a37a2411fc is described below

commit a37a2411fcabe9d83676d4fd073296fe6bbd3634
Author: Prateek Khandelwal <prkhandel...@linkedin.com>
AuthorDate: Thu Mar 6 20:01:42 2025 +0530

    Prevent dagProcessingEngine thread termination by handling exceptions 
gracefully (#4105)
---
 .github/workflows/build_and_test.yaml                        | 12 ++++++------
 .../service/modules/orchestration/task/LaunchDagTask.java    |  3 +--
 2 files changed, 7 insertions(+), 8 deletions(-)

diff --git a/.github/workflows/build_and_test.yaml 
b/.github/workflows/build_and_test.yaml
index 5149598ec1..78b6d6c846 100644
--- a/.github/workflows/build_and_test.yaml
+++ b/.github/workflows/build_and_test.yaml
@@ -38,7 +38,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Check out the repo
-        uses: actions/checkout@v2
+        uses: actions/checkout@v3
         with:
           persist-credentials: false
       - name: Set up JDK 1.8
@@ -47,7 +47,7 @@ jobs:
           java-version: 1.8
       # Stores external dependencies, can be further improved with Gradle 6.1
       - name: Cache Gradle Dependencies
-        uses: actions/cache@v2
+        uses: actions/cache@v3
         with:
           path: |
             ~/.gradle/caches
@@ -70,14 +70,14 @@ jobs:
     needs: build
     steps:
       - name: Check out the repo
-        uses: actions/checkout@v2
+        uses: actions/checkout@v3
       - name: Set up JDK 1.8
         uses: actions/setup-java@v1
         with:
           java-version: 1.8
       # Stores external dependencies, can be further improved with Gradle 6.1
       - name: Cache Gradle Dependencies
-        uses: actions/cache@v2
+        uses: actions/cache@v3
         with:
           path: |
             ~/.gradle/caches
@@ -112,7 +112,7 @@ jobs:
         options: --health-cmd="mysqladmin ping" --health-interval=10s 
--health-timeout=5s --health-retries=5
     steps:
       - name: Check out the repo
-        uses: actions/checkout@v2
+        uses: actions/checkout@v3
         with:
           persist-credentials: false
       - name: Set up JDK 1.8
@@ -137,7 +137,7 @@ jobs:
             mysql --host 127.0.0.1 --port 3306 -uroot -ptestPassword -e "SHOW 
DATABASES"
             mysql --host 127.0.0.1 --port 3306 -uroot -ptestPassword -e "SET 
GLOBAL max_connections=2000"
       - name: Cache Gradle Dependencies
-        uses: actions/cache@v2
+        uses: actions/cache@v3
         with:
           path: |
             ~/.gradle/caches
diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/LaunchDagTask.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/LaunchDagTask.java
index 67fe810d39..fa3f291d92 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/LaunchDagTask.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/LaunchDagTask.java
@@ -59,8 +59,7 @@ public class LaunchDagTask extends DagTask {
         return true;
       }
     } catch (SpecNotFoundException | URISyntaxException e) {
-      log.error("Unable to retrieve flowSpec to delete from flowCatalog if 
adhoc.");
-      throw new RuntimeException(e);
+      log.error("Unable to retrieve flowSpec to delete from flowCatalog if 
adhoc.", e);
     }
     return false;
   }