From 52f07cad54ad2fe7a066baecf7c6e18ad648a9e5 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Thu, 17 Sep 2020 10:33:11 -0700 Subject: [PATCH] Lint cleanup Small cleanup leftover from https://github.com/dpkp/kafka-python/pull/2035 --- kafka/admin/client.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/kafka/admin/client.py b/kafka/admin/client.py index 97fe73acb..1fcd88ccc 100644 --- a/kafka/admin/client.py +++ b/kafka/admin/client.py @@ -1,6 +1,6 @@ from __future__ import absolute_import -from collections import defaultdict, namedtuple +from collections import defaultdict import copy import logging import socket @@ -708,7 +708,6 @@ def create_acls(self, acls): self._wait_for_futures([future]) response = future.value - return self._convert_create_acls_response_to_acls(acls, response) @staticmethod @@ -1028,7 +1027,6 @@ def _describe_consumer_groups_process_response(self, response): assert len(response.groups) == 1 for response_field, response_name in zip(response.SCHEMA.fields, response.SCHEMA.names): if isinstance(response_field, Array): - described_groups = response.__dict__[response_name] described_groups_field_schema = response_field.array_of described_group = response.__dict__[response_name][0] described_group_information_list = [] @@ -1055,7 +1053,8 @@ def _describe_consumer_groups_process_response(self, response): described_group_information_list.append(member_information_list) else: described_group_information_list.append(described_group_information) - # Version 3 of the DescribeGroups API introduced the "authorized_operations" field. This will cause the namedtuple to fail + # Version 3 of the DescribeGroups API introduced the "authorized_operations" field. + # This will cause the namedtuple to fail. # Therefore, appending a placeholder of None in it. if response.API_VERSION <=2: described_group_information_list.append(None)