|
|
@ -255,8 +255,7 @@ impl<'a> SessionTx<'a> {
|
|
|
|
.try_collect()?,
|
|
|
|
.try_collect()?,
|
|
|
|
);
|
|
|
|
);
|
|
|
|
let key = relation_store.adhoc_encode_key(&extracted, *span)?;
|
|
|
|
let key = relation_store.adhoc_encode_key(&extracted, *span)?;
|
|
|
|
let existing = self.tx.get(&key, true)?;
|
|
|
|
if self.tx.exists(&key, true)? {
|
|
|
|
if existing.is_some() {
|
|
|
|
|
|
|
|
bail!(TransactAssertionFailure {
|
|
|
|
bail!(TransactAssertionFailure {
|
|
|
|
relation: relation_store.name.to_string(),
|
|
|
|
relation: relation_store.name.to_string(),
|
|
|
|
key: extracted.0,
|
|
|
|
key: extracted.0,
|
|
|
|