dragonflyoss
/
dragonfly
mirror of https://github.com/dragonflyoss/dragonfly.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore: update rust client version (#3403) 

Signed-off-by: Gaius <gaius.qi@gmail.com>
This commit is contained in:
Gaius 2024-07-31 13:26:39 +08:00 committed by GitHub
parent 934ce3a2b5
commit 97f21cfbf5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client-rs

@ -1 +1 @@
Subproject commit 97791be3892216c9335cbad145b592ff03905474 Subproject commit ef7a6df21a9947317edf2b51de834efbe5bcaccc

4
internal/job/job.go
View File

@ -105,6 +105,7 @@ type GroupJobState struct {
GroupUUID string GroupUUID string
State string State string
CreatedAt time.Time CreatedAt time.Time
UpdatedAt time.Time
JobStates []*machineryv1tasks.TaskState JobStates []*machineryv1tasks.TaskState
} }
@ -125,6 +126,7 @@ func (t *Job) GetGroupJobState(groupID string) (*GroupJobState, error) {
GroupUUID: groupID, GroupUUID: groupID,
State: machineryv1tasks.StateFailure, State: machineryv1tasks.StateFailure,
CreatedAt: taskState.CreatedAt, CreatedAt: taskState.CreatedAt,
UpdatedAt: time.Now(),
JobStates: taskStates, JobStates: taskStates,
}, nil }, nil
} }
@ -137,6 +139,7 @@ func (t *Job) GetGroupJobState(groupID string) (*GroupJobState, error) {
GroupUUID: groupID, GroupUUID: groupID,
State: machineryv1tasks.StatePending, State: machineryv1tasks.StatePending,
CreatedAt: taskState.CreatedAt, CreatedAt: taskState.CreatedAt,
UpdatedAt: time.Now(),
JobStates: taskStates, JobStates: taskStates,
}, nil }, nil
} }
@ -146,6 +149,7 @@ func (t *Job) GetGroupJobState(groupID string) (*GroupJobState, error) {
GroupUUID: groupID, GroupUUID: groupID,
State: machineryv1tasks.StateSuccess, State: machineryv1tasks.StateSuccess,
CreatedAt: taskStates[0].CreatedAt, CreatedAt: taskStates[0].CreatedAt,
UpdatedAt: time.Now(),
JobStates: taskStates, JobStates: taskStates,
}, nil }, nil
} }