feat(rst): TODO merge - fix rst provider IsWorkRequestReady() error handling

swartzn · swartzn · commit c0f3c149cb49 · 2025-07-01T12:31:31.000-05:00
diff --git a/rst/sync/internal/workmgr/work.go b/rst/sync/internal/workmgr/work.go
@@ -287,10 +287,11 @@ func (w *worker) processWork(work workAssignment) {
 	ready, retryTime, err := client.IsWorkRequestReady(work.ctx, request.WorkRequest)
 	if err != nil {
 		status.SetState(flex.Work_FAILED)
-		status.SetMessage("failed to determine if work request is ready")
+		status.SetMessage("failed to determine if work request is ready: " + err.Error())
 		if w.sendWorkResult(work, result.Work) {
 			cleanupEntries = true
 		}
+		return
 	}
 	if !ready {
 		status.SetMessage("waiting for work request to be ready")

Original file line number	Diff line number	Diff line change
`@@ -287,10 +287,11 @@ func (w *worker) processWork(work workAssignment) {`
`287`	`287`	`ready, retryTime, err := client.IsWorkRequestReady(work.ctx, request.WorkRequest)`
`288`	`288`	`if err != nil {`
`289`	`289`	`status.SetState(flex.Work_FAILED)`
`290`		`- status.SetMessage("failed to determine if work request is ready")`
	`290`	`+ status.SetMessage("failed to determine if work request is ready: " + err.Error())`
`291`	`291`	`if w.sendWorkResult(work, result.Work) {`
`292`	`292`	`cleanupEntries = true`
`293`	`293`	`}`
	`294`	`+ return`
`294`	`295`	`}`
`295`	`296`	`if !ready {`
`296`	`297`	`status.SetMessage("waiting for work request to be ready")`