diff options
Diffstat (limited to 'jstests/change_streams/apply_ops.js')
| -rw-r--r-- | jstests/change_streams/apply_ops.js | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/jstests/change_streams/apply_ops.js b/jstests/change_streams/apply_ops.js index ee116d3495d..5212f16e14b 100644 --- a/jstests/change_streams/apply_ops.js +++ b/jstests/change_streams/apply_ops.js @@ -72,7 +72,7 @@ ns: {db: db.getName(), coll: coll.getName()}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }, { documentKey: {_id: 2}, @@ -80,7 +80,7 @@ ns: {db: db.getName(), coll: coll.getName()}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }, { documentKey: {_id: 1}, @@ -88,14 +88,14 @@ operationType: "update", updateDescription: {removedFields: [], updatedFields: {a: 1}}, lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }, { documentKey: {_id: kDeletedDocumentId}, ns: {db: db.getName(), coll: coll.getName()}, operationType: "delete", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }, { operationType: "drop", @@ -123,7 +123,7 @@ ns: {db: db.getName(), coll: otherCollName}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }); // Verify that a whole-db stream returns the expected sequence of changes, including the insert @@ -141,7 +141,7 @@ ns: {db: otherDbName, coll: otherDbCollName}, operationType: "insert", lsid: session.getSessionId(), - txnNumber: NumberLong(session._txnNumber), + txnNumber: session.getTxnNumber_forTesting(), }); // Verify that a whole-cluster stream returns the expected sequence of changes, including the |