Dont warn in AutoCommitTask.disable if not previously scheduled

2015-12-29 17:36:11 -08:00
parent 6e20e0bb52
commit 563e38a84f
1 changed files with 1 additions and 1 deletions
--- a/kafka/coordinator/consumer.py
+++ b/kafka/coordinator/consumer.py
@@ -540,7 +540,7 @@ class AutoCommitTask(object):
        try:
            self._client.unschedule(self)
        except KeyError:
-            log.warning("AutoCommitTask was not previously scheduled")
+            pass

    def _reschedule(self, at):
        if self._enabled: