diff --git a/src/NRedisStack/Pipeline.cs b/src/NRedisStack/Pipeline.cs index a29b3983..c858413f 100644 --- a/src/NRedisStack/Pipeline.cs +++ b/src/NRedisStack/Pipeline.cs @@ -6,6 +6,7 @@ public class Pipeline { public Pipeline(IDatabase db) { + db.SetInfoInPipeline(); _batch = db.CreateBatch(); } diff --git a/tests/NRedisStack.Tests/PipelineTests.cs b/tests/NRedisStack.Tests/PipelineTests.cs index cc5d7621..2c329fa7 100644 --- a/tests/NRedisStack.Tests/PipelineTests.cs +++ b/tests/NRedisStack.Tests/PipelineTests.cs @@ -156,4 +156,22 @@ public void TestJsonPipeline(string endpointId) Assert.True(setResponse.Result); Assert.Equal("{\"Name\":\"Shachar\",\"Age\":23}", getResponse.Result.ToString()); } + + [SkippableTheory] + [MemberData(nameof(EndpointsFixture.Env.StandaloneOnly), MemberType = typeof(EndpointsFixture.Env))] + [Obsolete] + public async void Issue401_TestPipelineAsInitialCommand(string endpointId) + { + IDatabase db = GetCleanDatabase(endpointId); + + Auxiliary.ResetInfoDefaults(); // demonstrate first connection + var pipeline = new Pipeline(db); + + var setTask = pipeline.Json.SetAsync("json-key", "$", "{}"); + _ = pipeline.Db.KeyExpireAsync(key, TimeSpan.FromSeconds(10)); + + pipeline.Execute(); + + Assert.True(await setTask); + } } \ No newline at end of file