diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-29 17:36:11 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-29 17:36:11 -0800 |
| commit | 563e38a84f75d2ce3df23f1734d08feaaefe24b6 (patch) | |
| tree | fa507afe054a6e38f5a90b1af88545aec40eeddb | |
| parent | 6e20e0bb52143955e49a3edca77153b5aba58148 (diff) | |
| download | kafka-python-563e38a84f75d2ce3df23f1734d08feaaefe24b6.tar.gz | |
Dont warn in AutoCommitTask.disable if not previously scheduled
| -rw-r--r-- | kafka/coordinator/consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 67b4b6d..92a840d 100644 --- 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: |