delta/python-packages/kafka-python.git/kafka/future.py, branch struct-pre-compilation

Always absolute_import

2016-08-03T04:36:00+00:00

Simplify RecordMetadata; short circuit callbacks (#768)

2016-07-17T17:17:10+00:00

  Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization
  Minor optimization: inline check for no callbacks

Cleanup error logging (#760 / #759)

2016-07-16T04:26:53+00:00

  - add error type to all KafkaErrors
  - add args to BrokerResponseError
  - drop description from BrokerResponseError
  - fix bug logging errbacks as callbacks

use the same logic for callbacks regardless of is_done status

2016-04-25T21:22:51+00:00

Remove unused imports

2016-04-05T17:22:54+00:00

Update imports from kafka.common -> kafka.errors / kafka.structs

2016-04-05T16:35:45+00:00

Coerce exceptions to bool in Future.succeeded() and Future.failed()

2016-04-05T07:16:15+00:00

Call errbacks with future.exception

2016-01-04T07:31:09+00:00

Prefer assert or more-specific error to IllegalState / IllegalArgument

2015-12-31T00:16:13+00:00

Improvements to kafka.future.Future

2015-12-28T22:57:54+00:00

 - log exceptions in callbacks/errors - dont raise
 - guarantee future.exception is an instance, not a class/type
 - *args, **kwargs in add_callback / errback (functools.partial)
 - add_both(f, *args, **kwargs) to add same f as callback and errback
 - chain(new_future) to trigger new_future on success / failure of this