Ecosyste.ms: OpenCollective

An open API service for software projects hosted on Open Collective.

github.com/taskiq-python/taskiq-aio-kafka

Kafka broker for taskiq
https://github.com/taskiq-python/taskiq-aio-kafka

Merge branch 'release/0.2.0'

2238311a343806830b1a232b9c0227bdd19c4eac authored over 1 year ago by Pavel Kirilin <[email protected]>
Version bumped to 0.2.0

Signed-off-by: Pavel Kirilin <[email protected]>

75633953c5e12d8feaa8c033928978d5fb722fc6 authored over 1 year ago by Pavel Kirilin <[email protected]>
Updated classifiers.

Signed-off-by: Pavel Kirilin <[email protected]>

b7031d1119ec02f4d683dde54b1499368ff530e0 authored over 1 year ago by Pavel Kirilin <[email protected]>
Merge pull request #2 from taskiq-python/feature/deps-update

73c199a35cdca4823ee84b9690c32b099bf365f4 authored over 1 year ago by Pavel Kirilin <[email protected]>
Fixed tests.

Signed-off-by: Pavel Kirilin <[email protected]>

ed774ebc5740f081bbd8c8929d1c62c51054e57d authored over 1 year ago by Pavel Kirilin <[email protected]>
Fixed workflows.

Signed-off-by: Pavel Kirilin <[email protected]>

fbd42d025fc8ab8cfbbbd62acddbd2d5b6e122a8 authored over 1 year ago by Pavel Kirilin <[email protected]>
Dependencies update, fixed some lints.

Signed-off-by: Pavel Kirilin <[email protected]>

649abf4d8bfd5776fff43899bf08b60ab15d16a5 authored over 1 year ago by Pavel Kirilin <[email protected]>
Finish 0.1.2

8ff849d3d29863f965ae39b113dbe76fbca28f02 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Finish 0.1.2

b6a691be62404672b2e1d25aaddeeead640417a6 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Bumped version in pyproject to 0.1.2

2283921a1289112cd0d3a2faee650a76f1b4b2d5 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Merge pull request #1 from taskiq-python/remove_aiokafka_consumer_aiokafka_producer

Removed aiokafka_consumer and aiokafka_producer from broker arguments

371120a1198002874327ff9510496eef136b5690 authored over 1 year ago by Aleksandr Kiselev <[email protected]>
Removed aiokafka_consumer and aiokafka_producer from broker arguments

8aa9cece36727f76e9fab99eac1a4454dddec082 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Merge branch 'main' into develop

c0e735e9b1e0b6fe89a2a53093e7030ff97567d0 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Finish 0.1.1

39829283d2cc939b9d37360c203df2ea1de2d8fc authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Finish 0.1.1

0aa9cdff4e35ff69aa5718d67c90b05d7265223c authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Bumped version in pyproject to 0.1.1

4fb2dd79ef487d5d7aa033f36c6ce8f138666533 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Improved tests

5bdb42022c4600bff64ebbe3b89105bf9edf242a authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Updated README to latest changes

9c0f5269295e4fc292a6c3ddfacd24930edf148d authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Add new classes that describe parameters for kafka producer and consumer cuz AIOKafkaProducer and AIOKafkaConsumer must be initialize in async method or with passed loop parameter.

c179375eef9dc62d1844f609a33078b821e104a7 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Move AIOKafkaProducer and AIOKafkaConsumer initialization to startup

9f3ee0093fe19e3cb35ce529784f1290296c1387 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Change kick method to new interface

a8f6548ceb8ebf0346c3950d7bf0fefb2cbfd753 authored over 1 year ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Removed pydantic.

5a0cff8b9ef3f3af690b7f2700d7d8ee8c0698fe authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Fix lints

6b4ce80b4ecb4e964f5ce73004b05ef4034610be authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Fix lints

5ca377aec989cbfb4c3ed71dd49c1e25bdebacf0 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Fix tests and move _loop upper in broker init methid

933b7549892b7151d466be6dc7a258f851c58df2 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Remove delays from README

b879371b0af57c6fbc24ab94230db72649d11b4d authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Change broker and tests

7e3b4ca4dce911c9a795af60e3a531925f578e90 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
actions fix

a8fbf6803c5e58a081fd8151955e6e48f4a22e4b authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
pre-commit fix

a715c20b1af20f0849a18657479d8e474ecc9ffa authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Rename package

a895751679bce7f3611bc5fcefe44bec8db6ecdc authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Rename package

d151ee4cd32b667b19b589fd2af3ce4b954ee414 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Lint fixes

f8cd6d0a75bbea6206fee84e1b4e957299e71751 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Lint fixes

1b8a9c1d29a014eedad7373cfff92b2c64626a58 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Small docs fixes

28bb4f6125acf774f767612e7b4ef0b48ca1314f authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Added README.md

9435d3c44063b8d6f5a04c6aa3d766799cbcdbaf authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Added tests

61ab24af8fbdfed77e69a7371eaef8cae4127f3b authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Added priority functional

a97b5bd7f5e9f9f77a47c48e4daa3ca007424439 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Added delay functionality.

aed631bc7a29e5e4e0e33e0bb2885e3eabb83823 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Add shutdown method

7c0831ea4a1be7cf27439959588d47df75e33f52 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
Default implementation of Kafka broker

f8faec1372d484f080bef65b08f1c4d4ba3f5cf5 authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>
repo init

876f992592b5a6e272f9bf1cd36de32e87ff89de authored almost 2 years ago by chandr-andr (Kiselev Aleksandr) <[email protected]>