back round 1 view raw

spindle: expose knot-side workflow errors as a fake step to the UI #424

merged

opened by

winter.bsky.social 4 months ago targeting master from winter.bsky.social/core: push-luoyqwkpromz

Signed-off-by: Winter winter@winter.cafe

options

unified split

Changed files

+31

spindle

stream.go

+31

spindle/stream.go

···

       6
       6
        
       	"fmt"

     

       7
       7
        
       	"io"

     

       8
       8
        
       	"net/http"

     

       9
       9
       +
       	"os"

     

       9
       10
        
       	"strconv"

     

       10
       11
        
       	"time"

     

       11
       12
        
       

     
···

       144
       145
        
       

     

       145
       146
        
       	filePath := models.LogFilePath(s.cfg.Server.LogDir, wid)

     

       146
       147
        
       

     

       148
       148
       +
       	if status.Status == models.StatusKindFailed.String() && status.Error != nil {

     

       149
       149
       +
       		if _, err := os.Stat(filePath); os.IsNotExist(err) {

     

       150
       150
       +
       			msgs := []models.LogLine{

     

       151
       151
       +
       				{

     

       152
       152
       +
       					Kind:     models.LogKindControl,

     

       153
       153
       +
       					Content:  "",

     

       154
       154
       +
       					StepId:   0,

     

       155
       155
       +
       					StepKind: models.StepKindUser,

     

       156
       156
       +
       				},

     

       157
       157
       +
       				{

     

       158
       158
       +
       					Kind:    models.LogKindData,

     

       159
       159
       +
       					Content: *status.Error,

     

       160
       160
       +
       				},

     

       161
       161
       +
       			}

     

       162
       162
       +
       

     

       163
       163
       +
       			for _, msg := range msgs {

     

       164
       164
       +
       				b, err := json.Marshal(msg)

     

       165
       165
       +
       				if err != nil {

     

       166
       166
       +
       					return err

     

       167
       167
       +
       				}

     

       168
       168
       +
       

     

       169
       169
       +
       				if err := conn.WriteMessage(websocket.TextMessage, b); err != nil {

     

       170
       170
       +
       					return fmt.Errorf("failed to write to websocket: %w", err)

     

       171
       171
       +
       				}

     

       172
       172
       +
       			}

     

       173
       173
       +
       

     

       174
       174
       +
       			return nil

     

       175
       175
       +
       		}

     

       176
       176
       +
       	}

     

       177
       177
       +
       

     

       147
       178
        
       	config := tail.Config{

     

       148
       179
        
       		Follow:    !isFinished,

     

       149
       180
        
       		ReOpen:    !isFinished,