This is an automated email from the ASF dual-hosted git repository.
wlo 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 ea1233a31 [GOBBLIN-2071] Adds execution start timer to temporal (#3953)
ea1233a31 is described below
commit ea1233a31cd3b185aac2bd40d8e1139327873e9e
Author: William Lo <[email protected]>
AuthorDate: Tue May 28 14:29:41 2024 -0400
[GOBBLIN-2071] Adds execution start timer to temporal (#3953)
---
.../gobblin/temporal/ddm/workflow/impl/ExecuteGobblinWorkflowImpl.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ExecuteGobblinWorkflowImpl.java
b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ExecuteGobblinWorkflowImpl.java
index 9d6776a13..7760883e9 100644
---
a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ExecuteGobblinWorkflowImpl.java
+++
b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ExecuteGobblinWorkflowImpl.java
@@ -75,6 +75,7 @@ public class ExecuteGobblinWorkflowImpl implements
ExecuteGobblinWorkflow {
@Override
public ExecGobblinStats execute(Properties jobProps, EventSubmitterContext
eventSubmitterContext) {
TemporalEventTimer.Factory timerFactory = new
TemporalEventTimer.Factory(eventSubmitterContext);
+ timerFactory.create(TimingEvent.LauncherTimings.JOB_PREPARE).submit();
EventTimer timer = timerFactory.createJobTimer();
try {
int numWUsGenerated = genWUsActivityStub.generateWorkUnits(jobProps,
eventSubmitterContext);