def commit_partition_offsets(self, partition_offsets):
        self.logger.debug("Committing partition offsets: %s", partition_offsets)

        commit_requests = [
            OffsetCommitRequestPayload(self.consumer.topic, partition, offset, None)
            for partition, offset in partition_offsets.items()
        ]
        commit_responses = self.consumer.client.send_offset_commit_request(
            self.consumer.group,
            commit_requests,
        )
        for commit_response in commit_responses:
            check_error(commit_response)
If a dotted name is imported and used, no warning is reported.
dataset/ETHPy150Open dpkp/kafka-python/kafka/context.py/OffsetCommitContext.commit_partition_offsets--crossover with--dataset/ETHPy150Open patrys/PythonChecker/pyflakes/test/test_imports.py/Test.test_packageImport