diff options
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 914afec..747a85f 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -292,14 +292,14 @@ class KafkaClient(object): metadata_timeout = self._maybe_refresh_metadata() # Send scheduled tasks - for task, future in self._delayed_tasks.pop_ready(): + for task, task_future in self._delayed_tasks.pop_ready(): try: result = task() except Exception as e: log.error("Task %s failed: %s", task, e) - future.failure(e) + task_future.failure(e) else: - future.success(result) + task_future.success(result) timeout = min(timeout_ms, metadata_timeout, self.config['request_timeout_ms']) |