We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a333938 commit 83cd021Copy full SHA for 83cd021
src/pl_funcs.c
@@ -180,7 +180,6 @@ remove_on_xact_abort_callbacks(void *arg)
180
else
181
UnregisterSubXactCallback(on_subxact_abort_callback, arg);
182
183
- Assert(parg->expired == true); /* the job should always be done */
184
pfree(arg);
185
}
186
@@ -223,7 +222,8 @@ on_xact_abort_callback(XactEvent event, void *arg)
223
222
part_abort_arg *parg = (part_abort_arg *) arg;
224
225
/* Check that this is an aborted Xact & action has not expired yet */
226
- if (event == XACT_EVENT_ABORT && !parg->expired)
+ if ((event == XACT_EVENT_ABORT || event == XACT_EVENT_PARALLEL_ABORT) &&
+ !parg->expired)
227
{
228
handle_part_event_cancellation(parg);
229
0 commit comments