diff --git a/bcs-common/common/task/revokers/etcd/revoke.go b/bcs-common/common/task/revokers/etcd/revoke.go index 9fac90291e..4186f1ec5f 100644 --- a/bcs-common/common/task/revokers/etcd/revoke.go +++ b/bcs-common/common/task/revokers/etcd/revoke.go @@ -145,7 +145,7 @@ func (b *etcdRevoker) cleanupRevokeSign() { defer b.mtx.Unlock() for taskID, sign := range b.revokeSignMap { - if time.Since(sign.registerTime) > time.Hour*24 { + if time.Since(sign.registerTime) > time.Hour*24*3 { sign.cancel() delete(b.revokeSignMap, taskID) } diff --git a/bcs-common/common/task/stores/mysql/table.go b/bcs-common/common/task/stores/mysql/table.go index 1a2162c62b..844d017a79 100644 --- a/bcs-common/common/task/stores/mysql/table.go +++ b/bcs-common/common/task/stores/mysql/table.go @@ -94,7 +94,7 @@ type StepRecord struct { Params map[string]string `json:"input" gorm:"type:text;serializer:json"` Payload string `json:"payload" gorm:"type:text"` Status string `json:"status" gorm:"type:varchar(255)"` - Message string `json:"message" gorm:"type:varchar(255)"` + Message string `json:"message" gorm:"type:text"` ETA *time.Time `json:"eta"` SkipOnFailed bool `json:"skipOnFailed"` RetryCount uint32 `json:"retryCount"` @@ -142,6 +142,7 @@ func (t *StepRecord) ToStep() *types.Step { Payload: t.Payload, Status: t.Status, Message: t.Message, + ETA: t.ETA, SkipOnFailed: t.SkipOnFailed, RetryCount: t.RetryCount, MaxRetries: t.MaxRetries,