code: def success(self, value):
      assert not self.is_done, "Future is already complete"
      self.value = value
      self.is_done = True
      if self._callbacks:
          self._call_backs("callback", self._callbacks, self.value)
      return self
  
file_path: kafka-python/kafka/future.py
imports: from __future__ import absolute_import
  import functools
  import logging
label_desc: Use image node_id 5 for calling the Future obj's underlying member method code with example usage: obj.success(value) and returns: self