Function ReconnectJob

pkg/jobcontroller/jobcontroller.go:1052–1057

(ctx context.Context, jobId string, rtOpts *waveobj.RuntimeOpts)

}

func ReconnectJob(ctx context.Context, jobId string, rtOpts *waveobj.RuntimeOpts) error {
	_, err, _ := reconnectGroup.Do(jobId, func() (any, error) {
		return nil, doReconnectJob(ctx, jobId, rtOpts)
	})
	return err
}

func doReconnectJob(ctx context.Context, jobId string, rtOpts *waveobj.RuntimeOpts) error {
	job, err := wstore.DBMustGet[*waveobj.Job](ctx, jobId)