-
Notifications
You must be signed in to change notification settings - Fork 669
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add a rate limiter to Hive Client #213
Comments
@EngHabu I think we should add all of this to a ServiceAPI, that way this can be easily extended to all clients |
* updating catalog client to contain reservation handling API Signed-off-by: Daniel Rammer <[email protected]> * added PhaseWaitingForCache to indicate cache reservation exists Signed-off-by: Daniel Rammer <[email protected]> * added ReservationEntry to interface with cache reservation API Signed-off-by: Daniel Rammer <[email protected]> * added support for requesting a heartbeat_interval during GetOrExtendReservation requests to the datacatalog Signed-off-by: Daniel Rammer <[email protected]> * fixed lint issues Signed-off-by: Daniel Rammer <[email protected]> * replaced flyteidl repo with cache reservation version - need to change back before merge Signed-off-by: Daniel Rammer <[email protected]> * upated flyteidl version Signed-off-by: Daniel Rammer <[email protected]> * updated flyteidl version Signed-off-by: Daniel Rammer <[email protected]> * remove flyteidl replace in go.mod and updating to latest version Signed-off-by: Daniel Rammer <[email protected]> * added unit testes to catalog client Signed-off-by: Daniel Rammer <[email protected]> * added docs for exports Signed-off-by: Daniel Rammer <[email protected]> * fixed lint issues Signed-off-by: Daniel Rammer <[email protected]>
* Update fast_registration.py * update fast registration (flyteorg#216) Signed-off-by: Samhita Alla <[email protected]> * Modify TOC and add a mechanism to consider RST files (flyteorg#218) * update fast registration Signed-off-by: Samhita Alla <[email protected]> * modified TOC and added a mechanism to consider RST files Signed-off-by: Samhita Alla <[email protected]> * updated conf.py Signed-off-by: Samhita Alla <[email protected]> * modified TOC Signed-off-by: Samhita Alla <[email protected]> * edit fast registration (flyteorg#219) Signed-off-by: Samhita Alla <[email protected]> * Edit fast_registration.rst (flyteorg#220) * edit fast registration Signed-off-by: Samhita Alla <[email protected]> * removed unnecessary RST file Signed-off-by: Samhita Alla <[email protected]> * Fix conflicts in flyteorg#213 (flyteorg#230) Signed-off-by: Samhita Alla <[email protected]> * Revert "Fix conflicts in flyteorg#213 (flyteorg#230)" (flyteorg#231) This reverts commit 525fbbcfb8828ac2e0b6d75d637455bcff1b9d21. Co-authored-by: Samhita Alla <[email protected]>
Signed-off-by: Flyte-Bot <[email protected]> Co-authored-by: samhita-alla <[email protected]>
* updating catalog client to contain reservation handling API Signed-off-by: Daniel Rammer <[email protected]> * added PhaseWaitingForCache to indicate cache reservation exists Signed-off-by: Daniel Rammer <[email protected]> * added ReservationEntry to interface with cache reservation API Signed-off-by: Daniel Rammer <[email protected]> * added support for requesting a heartbeat_interval during GetOrExtendReservation requests to the datacatalog Signed-off-by: Daniel Rammer <[email protected]> * fixed lint issues Signed-off-by: Daniel Rammer <[email protected]> * replaced flyteidl repo with cache reservation version - need to change back before merge Signed-off-by: Daniel Rammer <[email protected]> * upated flyteidl version Signed-off-by: Daniel Rammer <[email protected]> * updated flyteidl version Signed-off-by: Daniel Rammer <[email protected]> * remove flyteidl replace in go.mod and updating to latest version Signed-off-by: Daniel Rammer <[email protected]> * added unit testes to catalog client Signed-off-by: Daniel Rammer <[email protected]> * added docs for exports Signed-off-by: Daniel Rammer <[email protected]> * fixed lint issues Signed-off-by: Daniel Rammer <[email protected]>
Hello 👋, This issue has been inactive for over 9 months. To help maintain a clean and focused backlog, we'll be marking this issue as stale and will close the issue if we detect no activity in the next 7 days. Thank you for your contribution and understanding! 🙏 |
Hello 👋, This issue has been inactive for over 9 months and hasn't received any updates since it was marked as stale. We'll be closing this issue for now, but if you believe this issue is still relevant, please feel free to reopen it. Thank you for your contribution and understanding! 🙏 |
Signed-off-by: Flyte-Bot <[email protected]> Co-authored-by: samhita-alla <[email protected]>
Signed-off-by: Flyte-Bot <[email protected]> Co-authored-by: samhita-alla <[email protected]>
Signed-off-by: Flyte-Bot <[email protected]> Co-authored-by: samhita-alla <[email protected]>
Hello 👋, this issue has been inactive for over 9 months. To help maintain a clean and focused backlog, we'll be marking this issue as stale and will engage on it to decide if it is still applicable. |
Motivation: Why do you think this is important?
Implement this TODO: https://github.com/lyft/flyteplugins/blob/master/go/tasks/plugins/hive/client/qubole_client.go#L70
Goal: What should the final outcome look like, ideally?
A configurable rate limiter for qubole/hive client
Describe alternatives you've considered
A clear and concise description of any alternative solutions or features you've considered.
Flyte component
[Optional] Propose: Link/Inline
If you have ideas about the implementation please propose the change. If inline keep it short, if larger then you link to an external document.
Additional context
Add any other context or screenshots about the feature request here.
Is this a blocker for you to adopt Flyte
Please let us know if this makes it impossible to adopt Flyte
The text was updated successfully, but these errors were encountered: