From d583647c5b0120d22af388761f6b2c952920116d Mon Sep 17 00:00:00 2001 From: Arnaud Date: Tue, 25 Feb 2025 13:52:37 +0100 Subject: [PATCH] Propagate CancelledError --- datastore/defaultimpl.nim | 2 ++ datastore/sql/sqliteds.nim | 2 ++ 2 files changed, 4 insertions(+) diff --git a/datastore/defaultimpl.nim b/datastore/defaultimpl.nim index 72cd4b3..6b40ecd 100644 --- a/datastore/defaultimpl.nim +++ b/datastore/defaultimpl.nim @@ -33,6 +33,8 @@ proc defaultModifyGetImpl*( try: (maybeNewData, aux) = await fn(maybeCurrentData) + except CancelledError as err: + raise err except CatchableError as err: return failure(err) diff --git a/datastore/sql/sqliteds.nim b/datastore/sql/sqliteds.nim index 82a2442..d6a42dd 100644 --- a/datastore/sql/sqliteds.nim +++ b/datastore/sql/sqliteds.nim @@ -62,6 +62,8 @@ method modifyGet*(self: SQLiteDatastore, key: Key, fn: ModifyGet): Future[?!seq[ try: (maybeNewData, aux) = await fn(maybeCurrentData) + except CancelledError as err: + raise err except CatchableError as err: return failure(err)