(gobblin) branch master updated: Send flow event if flow deadline is crossed (#4126)

[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 26b3b778f7 Send flow event if flow deadline is crossed (#4126)
26b3b778f7 is described below

commit 26b3b778f71b47531bfca2c88758b0a82801077e
Author: thisisArjit <thisisar...@gmail.com>
AuthorDate: Thu Aug 7 18:06:49 2025 +0530

    Send flow event if flow deadline is crossed (#4126)
---
 .../modules/orchestration/proc/EnforceFlowFinishDeadlineDagProc.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/EnforceFlowFinishDeadlineDagProc.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/EnforceFlowFinishDeadlineDagProc.java
index 0d4a21058a..7c850aabc3 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/EnforceFlowFinishDeadlineDagProc.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/EnforceFlowFinishDeadlineDagProc.java
@@ -63,6 +63,7 @@ public class EnforceFlowFinishDeadlineDagProc extends 
DeadlineEnforcementDagProc
       dag.setFlowEvent(TimingEvent.FlowTimings.FLOW_RUN_DEADLINE_EXCEEDED);
       dag.setMessage("Flow killed due to exceeding SLA of " + 
flowFinishDeadline + " ms");
       dagProcEngineMetrics.markDagActionsAct(getDagActionType(), true);
+      DagProcUtils.setAndEmitFlowEvent(eventSubmitter, dag, 
TimingEvent.FlowTimings.FLOW_RUN_DEADLINE_EXCEEDED);
     } else {
       dagProcEngineMetrics.markDagActionsAct(getDagActionType(), true);
       log.error("EnforceFlowFinishDeadline dagAction received before due time. 
flowStartTime {}, flowFinishDeadline {} ", flowStartTime, flowFinishDeadline);