commit | ea1233a31cd3b185aac2bd40d8e1139327873e9e | [log] [tgz] |
---|---|---|
author | William Lo <lo.william97@gmail.com> | Tue May 28 14:29:41 2024 -0400 |
committer | GitHub <noreply@github.com> | Tue May 28 14:29:41 2024 -0400 |
tree | 6294df2d8ba59140f49f5d423f448b66b9fb82b3 | |
parent | cc54cbb245c8249dfacf185bbf37f37e6b7791ee [diff] |
[GOBBLIN-2071] Adds execution start timer to temporal (#3953)
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 9d6776a..7760883 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 @@ @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);