diff --git a/src/NRedisStack/Pipeline.cs b/src/NRedisStack/Pipeline.cs index 67f23ff8..3035576b 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 cf4826fc..52ec7540 100644 --- a/tests/NRedisStack.Tests/PipelineTests.cs +++ b/tests/NRedisStack.Tests/PipelineTests.cs @@ -157,4 +157,20 @@ public void TestJsonPipeline() Assert.True(setResponse.Result); Assert.Equal("{\"Name\":\"Shachar\",\"Age\":23}", getResponse.Result.ToString()); } + + [SkipIfRedis(Is.OSSCluster)] + public async void Issue401_TestPipelineAsInitialCommand() + { + IDatabase db = redisFixture.Redis.GetDatabase(); + + 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