GROUNDWORK-3440: test

gwos · Oct 28, 2024 · 534cab1 · 534cab1
1 parent 1e64f3c
commit 534cab1
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/connectors/databricks/databricks.go b/connectors/databricks/databricks.go
@@ -85,10 +85,10 @@ func getJobsResources(databricksClient *client.DatabricksClient, from time.Time,
 						{
 							Name:           "run_latency_seconds",
 							CustomName:     "run_latency_seconds",
-							Value:          0,
+							Value:          0.0,
 							UnitType:       transit.UnitCounter,
-							StartTimestamp: &transit.Timestamp{Time: time.UnixMilli(run.StartTime).Add(-time.Millisecond)},
-							EndTimestamp:   &transit.Timestamp{Time: time.UnixMilli(run.StartTime)},
+							StartTimestamp: &transit.Timestamp{Time: time.UnixMilli(run.StartTime).Add(-(2 * time.Millisecond))},
+							EndTimestamp:   &transit.Timestamp{Time: time.UnixMilli(run.StartTime).Add(-time.Millisecond)},
 						},
 						{
 							Name:           "run_latency_seconds",
@@ -101,10 +101,10 @@ func getJobsResources(databricksClient *client.DatabricksClient, from time.Time,
 						{
 							Name:           "run_latency_seconds",
 							CustomName:     "run_latency_seconds",
-							Value:          0,
+							Value:          0.0,
 							UnitType:       transit.UnitCounter,
-							StartTimestamp: &transit.Timestamp{Time: time.UnixMilli(run.EndTime)},
-							EndTimestamp:   &transit.Timestamp{Time: time.UnixMilli(run.EndTime).Add(time.Millisecond)},
+							StartTimestamp: &transit.Timestamp{Time: time.UnixMilli(run.EndTime).Add(time.Millisecond)},
+							EndTimestamp:   &transit.Timestamp{Time: time.UnixMilli(run.EndTime).Add(2 * time.Millisecond)},
 						},
 					}...)
 				} else {