diff --git a/Cleipnir.ResilientFunctions b/Cleipnir.ResilientFunctions
index ee98fba..2721626 160000
--- a/Cleipnir.ResilientFunctions
+++ b/Cleipnir.ResilientFunctions
@@ -1 +1 @@
-Subproject commit ee98fba993e55161b46a96c9303df26552076c6e
+Subproject commit 2721626f8601ed634bd48519f2f6c963639ff98f
diff --git a/Cleipnir.Tests/Flows/FlowsWithResultTests.cs b/Cleipnir.Tests/Flows/FlowsWithResultTests.cs
index e886aa3..6a43ec2 100644
--- a/Cleipnir.Tests/Flows/FlowsWithResultTests.cs
+++ b/Cleipnir.Tests/Flows/FlowsWithResultTests.cs
@@ -74,7 +74,7 @@ public async Task CompletionOfScheduledFlowCanBeAwaited()
         var scheduled = await flows.Schedule("someInstanceId", "someParameter");
 
         // Flow uses non-suspending delay, so it completes directly
-        var result = await scheduled.Completion(maxWait: TimeSpan.FromSeconds(5));
+        var result = await scheduled.Completion(timeout: TimeSpan.FromSeconds(5));
         result.ShouldBe(1);
     }
 
diff --git a/ServiceBuses/Kafka/Cleipnir.Kafka.Tests/MessageTests.cs b/ServiceBuses/Kafka/Cleipnir.Kafka.Tests/MessageTests.cs
index 8d64986..f810adc 100644
--- a/ServiceBuses/Kafka/Cleipnir.Kafka.Tests/MessageTests.cs
+++ b/ServiceBuses/Kafka/Cleipnir.Kafka.Tests/MessageTests.cs
@@ -30,7 +30,7 @@ public async Task MultipleMessagesCanBeHandled()
                 )
         );
 
-        await scheduled.Completion(maxWait: TimeSpan.FromSeconds(15));
+        await scheduled.Completion(timeout: TimeSpan.FromSeconds(15));
     }
 
     private class TestFlow : Flow