-
Notifications
You must be signed in to change notification settings - Fork 1.5k
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
Robustify cloud deployment + include initial KEDA configuration #3094
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
491c24d
to
caa2966
Compare
@@ -146,6 +146,8 @@ def on_celeryd_init(sender: Any = None, conf: Any = None, **kwargs: Any) -> None | |||
def wait_for_redis(sender: Any, **kwargs: Any) -> None: | |||
"""Waits for redis to become ready subject to a hardcoded timeout. | |||
Will raise WorkerShutdown to kill the celery worker if the timeout is reached.""" | |||
if MULTI_TENANT: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Understand we don't need the checks for multi-tenant/cloud, but conditionals like this should be as high in the call stack as possible, not embedded in tool functions.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Completely agree! Moved all these checks up to the worker init
Description