Skip to content

Commit 763cf9f

Browse files
Adding rollback and tests functionallity (#23)
* Adding rollback and tests functionallity Signed-off-by: Ramon Navarro Bosch <ramon.nb@gmail.com> * Update .gitignore Co-authored-by: Andy Lok <andylokandy@hotmail.com> Signed-off-by: Ramon Navarro Bosch <ramon.nb@gmail.com> * Update pyproject.toml Co-authored-by: Andy Lok <andylokandy@hotmail.com> Signed-off-by: Ramon Navarro Bosch <ramon.nb@gmail.com> * Rollback returns Ok Signed-off-by: Ramon Navarro Bosch <ramon.nb@gmail.com> * Removing tests infra Signed-off-by: Ramon Navarro Bosch <ramon.nb@gmail.com> * Clean up Signed-off-by: Ramon Navarro Bosch <ramon.nb@gmail.com> Co-authored-by: Andy Lok <andylokandy@hotmail.com>
1 parent 1f3158e commit 763cf9f

File tree

2 files changed

+15
-0
lines changed

2 files changed

+15
-0
lines changed

.gitignore

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,3 +2,5 @@
22
*.so
33
__pycache__/
44
.vscode
5+
.python-version
6+
dist

src/transaction.rs

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -384,4 +384,17 @@ impl Transaction {
384384
Ok(Python::with_gil(|py| timestamp.to_object(py)))
385385
})
386386
}
387+
388+
fn rollback<'p>(&self, py: Python<'p>) -> PyResult<&'p PyAny> {
389+
let inner = self.inner.clone();
390+
future_into_py(py, async move {
391+
inner
392+
.write()
393+
.await
394+
.rollback()
395+
.await
396+
.map_err(to_py_execption)?;
397+
Ok(Python::with_gil(|py| py.None()))
398+
})
399+
}
387400
}

0 commit comments

Comments
 (0)