Function TestCacheHitRewrapsObjectResultForCurrentServer

dagql/cache_test.go:3481–3510

(t *testing.T)

}

func TestCacheHitRewrapsObjectResultForCurrentServer(t *testing.T) {
	t.Parallel()
	ctx := cacheTestContext(t.Context())
	cacheIface, err := NewCache(ctx, "", nil, nil)
	assert.NilError(t, err)
	ctx = ContextWithCache(ctx, cacheIface)

	srvA := cacheTestObjectResolverServer(t, 1)
	srvB := cacheTestObjectResolverServer(t, 2)
	ctxA := srvToContext(ctx, srvA)
	ctxB := srvToContext(ctx, srvB)

	objAAny, err := srvA.Root().Select(ctxA, srvA, Selector{Field: "obj"})
	assert.NilError(t, err)
	objA := objAAny.(ObjectResult[*cacheTestObject])
	assert.Assert(t, !objA.HitCache())
	markerAAny, err := objA.Select(ctxA, srvA, Selector{Field: "marker"})
	assert.NilError(t, err)
	assert.Equal(t, 1, cacheTestUnwrapInt(t, markerAAny))

	objBAny, err := srvB.Root().Select(ctxB, srvB, Selector{Field: "obj"})
	assert.NilError(t, err)
	objB := objBAny.(ObjectResult[*cacheTestObject])
	assert.Assert(t, objB.HitCache())
	markerBAny, err := objB.Select(ctxB, srvB, Selector{Field: "marker"})
	assert.NilError(t, err)
	assert.Equal(t, 2, cacheTestUnwrapInt(t, markerBAny))

	cacheTestReleaseSession(t, cacheIface, ctxA)
}

func TestInputSpecsInputsFromResultCallArgs(t *testing.T) {
	t.Parallel()