From 8fc014ccf1d706a5d3f0dd0cacc5d74b83c83613 Mon Sep 17 00:00:00 2001 From: Rowan Seymour Date: Fri, 5 Jan 2024 14:03:53 -0500 Subject: [PATCH] Fix interrupting with background flows --- core/tasks/handler/contact_tasks.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/tasks/handler/contact_tasks.go b/core/tasks/handler/contact_tasks.go index 88e772b25..6431461c6 100644 --- a/core/tasks/handler/contact_tasks.go +++ b/core/tasks/handler/contact_tasks.go @@ -287,7 +287,7 @@ func HandleChannelEvent(ctx context.Context, rt *runtime.Runtime, eventType mode } } - sessions, err := runner.StartFlowForContacts(ctx, rt, oa, flow, []*models.Contact{modelContact}, []flows.Trigger{trig}, hook, true) + sessions, err := runner.StartFlowForContacts(ctx, rt, oa, flow, []*models.Contact{modelContact}, []flows.Trigger{trig}, hook, flow.FlowType().Interrupts()) if err != nil { return nil, errors.Wrapf(err, "error starting flow for contact") } @@ -491,7 +491,7 @@ func handleMsgEvent(ctx context.Context, rt *runtime.Runtime, event *MsgEvent) e // otherwise build the trigger and start the flow directly trigger := tb.Build() - _, err = runner.StartFlowForContacts(ctx, rt, oa, flow, []*models.Contact{modelContact}, []flows.Trigger{trigger}, flowMsgHook, true) + _, err = runner.StartFlowForContacts(ctx, rt, oa, flow, []*models.Contact{modelContact}, []flows.Trigger{trigger}, flowMsgHook, flow.FlowType().Interrupts()) if err != nil { return errors.Wrapf(err, "error starting flow for contact") } @@ -599,7 +599,7 @@ func handleTicketEvent(ctx context.Context, rt *runtime.Runtime, event *models.T return errors.Errorf("unknown ticket event type: %s", event.EventType()) } - _, err = runner.StartFlowForContacts(ctx, rt, oa, flow, []*models.Contact{modelContact}, []flows.Trigger{flowTrigger}, nil, true) + _, err = runner.StartFlowForContacts(ctx, rt, oa, flow, []*models.Contact{modelContact}, []flows.Trigger{flowTrigger}, nil, flow.FlowType().Interrupts()) if err != nil { return errors.Wrapf(err, "error starting flow for contact") }