From 02579075d0fbf6406501bd7b37e65fecc3a95daa Mon Sep 17 00:00:00 2001 From: Shlomi Noach <shlomi-noach@github.com> Date: Thu, 11 Jan 2018 08:03:09 +0200 Subject: [PATCH] Call the throttler.Teardown --- go/logic/migrator.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/go/logic/migrator.go b/go/logic/migrator.go index 04e866a..3937a45 100644 --- a/go/logic/migrator.go +++ b/go/logic/migrator.go @@ -1262,4 +1262,9 @@ func (this *Migrator) teardown() { log.Infof("Tearing down streamer") this.eventsStreamer.Teardown() } + + if this.throttler != nil { + log.Infof("Tearing down throttler") + this.throttler.Teardown() + } }