diff --git a/src/HotChocolate/Core/src/Subscriptions.Postgres/PostgresChannelWriter.cs b/src/HotChocolate/Core/src/Subscriptions.Postgres/PostgresChannelWriter.cs
index 6f3cd5fd2d1..7a8fc8ee19b 100644
--- a/src/HotChocolate/Core/src/Subscriptions.Postgres/PostgresChannelWriter.cs
+++ b/src/HotChocolate/Core/src/Subscriptions.Postgres/PostgresChannelWriter.cs
@@ -126,7 +126,7 @@ private async Task HandleMessage(NpgsqlConnection connection, CancellationToken
             // if we cannot send the message we put it back into the channel
             foreach (var message in messages)
             {
-                await _channel.Writer.WriteAsync(message, ct);
+                await _channel.Writer.WriteAsync(message, CancellationToken.None);
             }
         }
     }