From 1113a33e96e8957d9c09589905dc498514ed0bc2 Mon Sep 17 00:00:00 2001 From: Rowan Seymour Date: Mon, 19 Jul 2021 17:18:19 -0500 Subject: [PATCH] Log error if marking event fire as fired fails --- core/tasks/campaigns/fire_campaign_event.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/core/tasks/campaigns/fire_campaign_event.go b/core/tasks/campaigns/fire_campaign_event.go index c9ef37992..a034cf85c 100644 --- a/core/tasks/campaigns/fire_campaign_event.go +++ b/core/tasks/campaigns/fire_campaign_event.go @@ -93,7 +93,10 @@ func (t *FireCampaignEventTask) Perform(ctx context.Context, rt *runtime.Runtime if len(contactMap) > 0 { rc := rp.Get() for _, failed := range contactMap { - marker.RemoveTask(rc, campaignsLock, fmt.Sprintf("%d", failed.FireID)) + rerr := marker.RemoveTask(rc, campaignsLock, fmt.Sprintf("%d", failed.FireID)) + if rerr != nil { + log.WithError(rerr).WithField("fire_id", failed.FireID).Error("error unmarking campaign fire") + } } rc.Close() }