search

joowani / kq

Kafka-based Job Queue for Python
http://kq.readthedocs.io
MIT License
571 stars 24 forks source link

Key support #3

Closed shashankmehra closed 7 years ago

shashankmehra commented 7 years ago

Use Kafka's in-order guarantee to support in-order tasks. To process certain tasks in order they were produced, simply enqueue them with the same key. Tasks with different keys or None as key, will be processed by a 'random' partition decided by kafka's default partitioner.

coveralls commented 7 years ago

Coverage Status

Coverage remained the same at 100.0% when pulling 4645ddfc99e2ec01a75de3f3fdc2da513099f5f4 on shashankmehra:key_support into 5f89dd3142709f69eeca73ca7620c3ef8574c2a4 on joowani:master.

coveralls commented 7 years ago

Coverage Status

Coverage remained the same at 100.0% when pulling 4645ddfc99e2ec01a75de3f3fdc2da513099f5f4 on shashankmehra:key_support into 5f89dd3142709f69eeca73ca7620c3ef8574c2a4 on joowani:master.

joowani commented 7 years ago

Thanks a lot for the PR @shashankmehra! This is great 👍 I will take a look and merge/give you feedback as soon as possible.

joowani commented 7 years ago

Hi @shashankmehra I think this looks good. I've created a dev branch for future development and merges. Could you please redirect your PR to it please? Thanks!

shashankmehra commented 7 years ago

Sure. Created https://github.com/joowani/kq/pull/4 Closing this one.