Skip to content

Commit

Permalink
fix: optimise workflow node status offload with compression and fallb…
Browse files Browse the repository at this point in the history
…ack and db stability, small fixes

Signed-off-by: 刘达 <[email protected]>
  • Loading branch information
刘达 committed Aug 10, 2024
1 parent 5da3e0a commit dec6fa8
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions workflow/packer/packer.go
Original file line number Diff line number Diff line change
Expand Up @@ -108,15 +108,15 @@ func compressWorkflow(wf *wfv1.Workflow) error {
return err
}
if large {
compressedSize, err1 := getSize(wf)
nodesSize, err2 := getNodeStatusSize(wf)
wf.Status.CompressedNodes = ""
wf.Status.Nodes = nodes
if err1 != nil {
compressedSize, err := getSize(wf)
if err != nil {
return err
}
if err2 != nil {
return err2
nodesSize, err := getNodeStatusSize(wf)
if err != nil {
return err
}
return fmt.Errorf("%s compressed size %d > maxSize %d or node status size %d > maxNodeStatusSize %d",
tooLarge, compressedSize, getMaxWorkflowSize(), nodesSize, getMaxNodeStatusSize())
Expand Down

0 comments on commit dec6fa8

Please sign in to comment.