infinyon / fluvio

Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
https://www.fluvio.io/
Apache License 2.0
3.79k stars 503 forks source link

Python client async and admin upgrade #3859

Closed digikata closed 6 months ago

digikata commented 7 months ago

Map missing fluvio rust crate async and admin interfaces to python.

Details in Fluvio-client-python repo https://github.com/infinyon/fluvio-client-python/issues/367

drc-infinyon commented 7 months ago

/bounty $750

algora-pbc[bot] commented 7 months ago

💎 $750 bounty created by InfinyOn 🙋 If you start working on this, comment /attempt #3859 along with your implementation plan 👉 To claim this bounty, submit a pull request that includes the text /claim #3859 somewhere in its body 📝 Before proceeding, please make sure you can receive payouts in your country 💵 Payment arrives in your account 2-5 days after the bounty is rewarded 💯 You keep 100% of the bounty award 🙏 Thank you for contributing to infinyon/fluvio!

👉 Add a bountyShare on socials

Attempt Started (GMT+3) Solution
🟢 @neo773 Feb 10, 2024, 10:04:06 PM WIP
🟢 @urbit-pilled Feb 11, 2024, 1:29:50 AM WIP
🟢 @Shylock-Hg Feb 16, 2024, 5:40:29 AM #375
neo773 commented 7 months ago

/attempt #3859

Algora profile Completed bounties Tech Active attempts Options
@neo773 81 bounties from 19 projects
TypeScript, Rust,
JavaScript & more
Cancel attempt
urbit-pilled commented 7 months ago

This is related to my work in https://github.com/infinyon/fluvio-client-python/pull/359

/attempt #3859 Algora profile Completed bounties Tech Active attempts Options
@urbit-pilled    1 InfinyOn bounty
+ 1 bounty from 1 project
Scala, Rust,
Python & more
Cancel attempt
Shylock-Hg commented 7 months ago

/attempt #3859

Algora profile Completed bounties Tech Active attempts Options
@Shylock-Hg 3 bounties from 2 projects
C++, C,
Shell & more
Cancel attempt
urbit-pilled commented 7 months ago

I was trying to implement async without changing the fluvio repo upstream with the Clone modifications, but I think this is a good solution @Shylock-Hg. You can takeover the bounty.

Shylock-Hg commented 7 months ago

I was trying to implement async without changing the fluvio repo upstream with the Clone modifications, but I think this is a good solution @Shylock-Hg. You can takeover the bounty.

Thanks for your agreement. I tried it too, but failed. It's really hard to resolve the lifetime of &self in Future, could you share your idea? I'm just curious.

digikata commented 7 months ago

Hi @Shylock-Hg , not sure if this helps, but in the core rust fluvio crate, when you generate an async stream, (e.g. https://docs.rs/fluvio/latest/fluvio/consumer/struct.MultiplePartitionConsumer.html#method.stream) the future delivers a stream that doesn't keep a reference to self of the MultiplePartitionConsumer.

Shylock-Hg commented 7 months ago

Hi @Shylock-Hg , not sure if this helps, but in the core rust fluvio crate, when you generate an async stream, (e.g. https://docs.rs/fluvio/latest/fluvio/consumer/struct.MultiplePartitionConsumer.html#method.stream) the future delivers a stream that doesn't keep a reference to self of the MultiplePartitionConsumer.

Thanks.

drc-infinyon commented 6 months ago

Hey @Shylock-Hg are you done with this. Can you claim the bounty if you are please. :)

drc-infinyon commented 6 months ago

@Shylock-Hg - This ticket is resolved.

You need to claim the bounty based on this workflow: https://docs.algora.io/bounties/workflow -

To claim a bounty on Github, navigate to your pull request that solves the bountied issue and add /claim <ISSUE_NUMBER> somewhere in the body of the PR.

algora-pbc[bot] commented 6 months ago

💡 @Shylock-Hg submitted a pull request that claims the bounty. You can visit your bounty board to reward.

Shylock-Hg commented 6 months ago

@Shylock-Hg - This ticket is resolved.

You need to claim the bounty based on this workflow: https://docs.algora.io/bounties/workflow -

To claim a bounty on Github, navigate to your pull request that solves the bountied issue and add /claim <ISSUE_NUMBER> somewhere in the body of the PR.

@drc-infinyon Hello, I had claim it in https://github.com/infinyon/fluvio-client-python/pull/375, but it doesn't wok, maybe it's not supported in anther repo. Should I request new dummy PR in this repo? Or as I known, there is a /tip instruction to do it too.

drc-infinyon commented 6 months ago

@Shylock-Hg it is fixed now. I am paying the bounty.

algora-pbc[bot] commented 6 months ago

@Shylock-Hg: Your claim has been rewarded! We'll notify you once it is processed.

algora-pbc[bot] commented 6 months ago

🎉🎈 @Shylock-Hg has been awarded $750! 🎈🎊