From 989b5bd65403a3484b4e08c85c65a1785de1bd14 Mon Sep 17 00:00:00 2001 From: Brett Buddin Date: Thu, 20 Aug 2020 10:46:47 -0400 Subject: [PATCH] fix(kv/task): Copy the latest success/failure fields when unmarshalling. --- kv/task.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/kv/task.go b/kv/task.go index 0c4a1264a24..092cd1b1adc 100644 --- a/kv/task.go +++ b/kv/task.go @@ -51,6 +51,8 @@ type kvTask struct { Offset influxdb.Duration `json:"offset,omitempty"` LatestCompleted time.Time `json:"latestCompleted,omitempty"` LatestScheduled time.Time `json:"latestScheduled,omitempty"` + LatestSuccess time.Time `json:"latestSuccess,omitempty"` + LatestFailure time.Time `json:"latestFailure,omitempty"` CreatedAt time.Time `json:"createdAt,omitempty"` UpdatedAt time.Time `json:"updatedAt,omitempty"` Metadata map[string]interface{} `json:"metadata,omitempty"` @@ -74,6 +76,8 @@ func kvToInfluxTask(k *kvTask) *influxdb.Task { Offset: k.Offset.Duration, LatestCompleted: k.LatestCompleted, LatestScheduled: k.LatestScheduled, + LatestSuccess: k.LatestSuccess, + LatestFailure: k.LatestFailure, CreatedAt: k.CreatedAt, UpdatedAt: k.UpdatedAt, Metadata: k.Metadata,