fix: cancellation before next query

This commit is contained in:
Jindřich Moravec 2024-01-28 22:21:03 +01:00
parent 18d47b54ce
commit 65a469e8b9

View file

@ -167,6 +167,9 @@ async fn handle_query<W>(writer: &mut W, state: &SharedDbState, query: String, t
where where
W: BackendProtoWriter + ProtoFlush + Send, W: BackendProtoWriter + ProtoFlush + Send,
{ {
// Make sure token is reset before next query
token.reset();
let operation = { let operation = {
let state = state.read().await; let state = state.read().await;
let db_schema = state.db_schema(); let db_schema = state.db_schema();