()
| 78 | |
| 79 | #[test] |
| 80 | fn commit_kv_graph() { |
| 81 | let (mut core, mut tx, mut rx, _dir) = make_core(); |
| 82 | |
| 83 | let resp = send_raw( |
| 84 | &mut core, |
| 85 | &mut tx, |
| 86 | &mut rx, |
| 87 | PhysicalPlan::Meta(MetaOp::TransactionBatch { |
| 88 | plans: vec![kv_put(b"kg1", b"val"), edge_put("g", "a", "b")], |
| 89 | }), |
| 90 | ); |
| 91 | assert_eq!(resp.status, Status::Ok); |
| 92 | let r = send_raw(&mut core, &mut tx, &mut rx, kv_get(b"kg1")); |
| 93 | assert_eq!(&*r.payload, b"val"); |
| 94 | } |
| 95 | |
| 96 | #[test] |
| 97 | fn rollback_kv_then_graph_fail() { |