@@ -72,7 +72,6 @@ export function SessionClose (context, data, wire) {
72
72
wire . writeResponse ( 'Session' , { id : sessionId } )
73
73
} )
74
74
. catch ( err => wire . writeError ( err ) )
75
- context . removeSession ( sessionId )
76
75
}
77
76
78
77
export function SessionRun ( context , data , wire ) {
@@ -169,7 +168,6 @@ export function RetryablePositive (context, data, wire) {
169
168
const { sessionId } = data
170
169
context . getTxsBySessionId ( sessionId ) . forEach ( tx => {
171
170
tx . resolve ( )
172
- context . removeTx ( tx . id )
173
171
} )
174
172
}
175
173
@@ -178,7 +176,6 @@ export function RetryableNegative (context, data, wire) {
178
176
const error = context . getError ( errorId ) || new Error ( 'Client error' )
179
177
context . getTxsBySessionId ( sessionId ) . forEach ( tx => {
180
178
tx . reject ( error )
181
- context . removeTx ( tx . id )
182
179
} )
183
180
}
184
181
@@ -207,7 +204,6 @@ export function TransactionRollback (context, data, wire) {
207
204
tx . rollback ( )
208
205
. then ( ( ) => wire . writeResponse ( 'Transaction' , { id } ) )
209
206
. catch ( e => wire . writeError ( e ) )
210
- context . removeTx ( id )
211
207
}
212
208
213
209
export function SessionLastBookmarks ( context , data , wire ) {
0 commit comments