diff --git a/http/task_test.go b/http/task_test.go index 174c21c475..a408a327fd 100644 --- a/http/task_test.go +++ b/http/task_test.go @@ -16,7 +16,6 @@ import ( ) func TestTaskService(t *testing.T) { - t.Skip("TODO(#14108): flaky test (https://github.com/influxdata/influxdb/issues/14108)") t.Parallel() servicetest.TestTaskService( t, diff --git a/kv/task.go b/kv/task.go index 4ce8560901..a6366ed2df 100644 --- a/kv/task.go +++ b/kv/task.go @@ -792,7 +792,10 @@ func (s *Service) deleteTask(ctx context.Context, tx Tx, id influxdb.ID) error { if err := taskBucket.Delete(key); err != nil { return ErrUnexpectedTaskBucketErr(err) } - return nil + + return s.deleteUserResourceMapping(ctx, tx, influxdb.UserResourceMappingFilter{ + ResourceID: task.ID, + }) } // FindLogs returns logs for a run.