Skip to content

Commit 4a0de3e

Browse files
author
Assaf Liebstein
committed
add-sleep
1 parent 0dd4b12 commit 4a0de3e

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

src/main/resources/lineage.properties

Whitespace-only changes.

src/main/scala/com/yotpo/metorikku/metric/Metric.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,8 @@ case class Metric(configuration: Configuration, metricDir: Option[File], metricN
100100
log.info(s"Starting to Write results of ${dataFrameName}")
101101
try {
102102
writer.write(dataFrame)
103+
//TODO: wait for the hook
104+
Thread.sleep(20000)
103105
outputConfig.reportLag match {
104106
case Some(true) => new MetricReporting().reportLagTime(dataFrame, outputConfig.reportLagTimeColumn,
105107
outputConfig.reportLagTimeColumnUnits, instrumentationProvider)

0 commit comments

Comments
 (0)