Skip to content

Commit 83ff592

Browse files
committed
[executor] Push timestamp on every update
1 parent 77f7683 commit 83ff592

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

executor/executor.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@ import (
4848
"github.com/AliceO2Group/Control/common/logger"
4949
"github.com/AliceO2Group/Control/executor/executorcmd"
5050
"github.com/AliceO2Group/Control/executor/protos"
51+
"github.com/golang/protobuf/proto"
5152
"github.com/mesos/mesos-go/api/v1/lib"
5253
"github.com/mesos/mesos-go/api/v1/lib/backoff"
5354
"github.com/mesos/mesos-go/api/v1/lib/encoding"
@@ -674,6 +675,7 @@ func protoString(s string) *string { return &s }
674675

675676
// update sends UPDATE to agent.
676677
func update(state *internalState, status mesos.TaskStatus) error {
678+
status.Timestamp = proto.Float64(float64(time.Now().Unix()))
677679
log.WithFields(logrus.Fields{
678680
"status": status.State.String(),
679681
"id": status.TaskID.Value,

0 commit comments

Comments
 (0)