(gobblin) branch master updated: Emit metrics if dag act throws exception (#4129)

[abhijain]

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

abhijain 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 5c5db48a9c Emit metrics if dag act throws exception (#4129)
5c5db48a9c is described below

commit 5c5db48a9c04a071dc95bc270cd6055381ddd8c6
Author: thisisArjit <thisisar...@gmail.com>
AuthorDate: Wed Aug 13 16:07:23 2025 +0530

    Emit metrics if dag act throws exception (#4129)
---
 .../apache/gobblin/service/modules/orchestration/proc/DagProc.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProc.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProc.java
index c84d0dca8b..2430193f0f 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProc.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProc.java
@@ -79,7 +79,12 @@ public abstract class DagProc<T> {
       throw e;
     }
       logContextualizedInfo("ready to process");
+    try {
       act(dagManagementStateStore, state, dagProcEngineMetrics);
+    } catch (Exception e) {
+      dagProcEngineMetrics.markDagActionsAct(getDagActionType(), false);
+      throw e;
+    }
       logContextualizedInfo("processed");
   }