Function readWorkspaceLockState

engine/server/session.go:1761–1782

(ctx context.Context, bk interface {
	ReadCallerHostFile(ctx context.Context, path string) ([]byte, error)
}, ws *core.Workspace)

}

func readWorkspaceLockState(ctx context.Context, bk interface {
	ReadCallerHostFile(ctx context.Context, path string) ([]byte, error)
}, ws *core.Workspace) (*workspace.Lock, error) {
	lockPath, err := workspaceLockPath(ws)
	if err != nil {
		return nil, err
	}

	data, err := bk.ReadCallerHostFile(ctx, lockPath)
	if err != nil {
		if isWorkspaceLockNotFound(err) {
			return workspace.NewLock(), nil
		}
		return nil, fmt.Errorf("reading lock: %w", err)
	}

	lock, err := workspace.ParseLock(data)
	if err != nil {
		return nil, fmt.Errorf("parsing lock: %w", err)
	}
	return lock, nil
}

func isWorkspaceLockNotFound(err error) bool {
	return errors.Is(err, os.ErrNotExist) || status.Code(err) == codes.NotFound