Fix/un 2910 fix prevent task duplication warm shutdown heartbeatkeeper #1617
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
…n with HeartbeatKeeper Implemented HeartbeatKeeper bootstep to maintain RabbitMQ connection during Celery warm shutdown, preventing task requeuing and duplication during Kubernetes rolling updates and graceful pod terminations. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <[email protected]>
for more information, see https://pre-commit.ci
…on (#1613) - Moved redis_client.py and redis_queue_client.py from workers/shared/cache/ to unstract/core/src/unstract/core/cache/ - Created new cache module in unstract-core with __init__.py exports - Updated all import statements across workers to use unstract.core.cache instead of shared.cache - Updated imports in log_consumer tasks and cache_backends to use new location - Maintains backward compatibility by keeping same API and functionality
#1605) Co-authored-by: harini-venkataraman <[email protected]>
… in prompt-service (#1585) UN-2830 Suppress OpenTelemetry EventLogger LogRecord deprecation warning in prompt-service Suppressed the LogDeprecatedInitWarning from OpenTelemetry SDK 1.37.0's EventLogger.emit() method which still uses deprecated trace_id/span_id/trace_flags parameters instead of the context parameter. This is a temporary workaround for an upstream bug in OpenTelemetry Python SDK where EventLogger.emit() was not updated when LogRecord API was changed to accept context parameter. The warning only appears in prompt-service because llama-index emits OpenTelemetry Events. See: open-telemetry/opentelemetry-python#4328 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-authored-by: Claude <[email protected]>
…ts (#1592) Add organization-level sharing for Prompt Studio projects Implemented organization-wide sharing functionality for CustomTool (Prompt Studio projects), bringing them to parity with workflows and adapters. Changes: - Added shared_to_org BooleanField to CustomTool model - Updated CustomToolModelManager.for_user() to include org-level filtering - Added shared_to_org field to SharedUserListSerializer - Updated permissions to use IsOwnerOrSharedUserOrSharedToOrg - Added email notifications for sharing events in partial_update() - Updated frontend ListOfTools component to support org-wide sharing - Created database migration for shared_to_org field Users can now share Prompt Studio projects with all members of their organization using the "Share with everyone in current org" checkbox. Email notifications are sent to users when projects are shared with them individually. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-authored-by: Claude <[email protected]> Co-authored-by: Gayathri <[email protected]> Co-authored-by: Athul <[email protected]>
…1588) * UN-2873 [FEAT] Add organization-level sharing support for adapters - Add shared_to_org field to SharedUserListSerializer to expose org-wide sharing status - Implement email notifications when adapters are shared with users - Use type-specific resource types (LLM, EMBEDDING, VECTOR_DB, X2TEXT) instead of generic adapter type - Add frontend support for org-wide sharing checkbox in adapter settings - Fix SharePermission component to disable org-wide checkbox in view-only mode - Add comprehensive documentation in prompting/tasks/ This extends the existing adapter sharing to support organization-wide access, bringing adapters to full parity with workflows and text extractors. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <[email protected]> * UN-2873 [FIX] Use logger.exception for better error traceback in adapter sharing - Change logger.error to logger.exception to automatically include traceback - Improves debugging when email notifications fail during adapter sharing 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <[email protected]> --------- Co-authored-by: Claude <[email protected]> Co-authored-by: Athul <[email protected]>
…#1615) Added build argument to control PostHog analytics at build time, enabling cloud deployments while disabling for on-prem installations. Changes: - Added REACT_APP_ENABLE_POSTHOG build argument to frontend Dockerfile - Defaults to true to maintain cloud behavior - Updated sample.env with PostHog configuration documentation - Default set to false for local development (privacy-first) This provides clean separation between cloud (analytics enabled) and on-prem (analytics disabled) builds without runtime complexity. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-authored-by: Claude <[email protected]>
* UN-2807 [FEAT] Add packet processing support for HITL workflows - Added packet_id parameter to API execution flow - Integrated packet-based routing in destination connector - Enhanced queue management to support packet-based review alongside traditional HITL queues - Updated DTOs and serializers to include packet_id field This enables workflows to be grouped into packets for batch review in HITL scenarios. 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude <[email protected]> * added missing references * added hitl prefix to query params * added try-catch on enterprise import * used app registry for plugin check * code refactor * used registry to find installed apps * sonar issue fix * changes for new worker implementation * [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --------- Signed-off-by: jagadeeswaran-zipstack <[email protected]> Co-authored-by: Claude <[email protected]> Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com> Co-authored-by: Athul <[email protected]>
…m-shutdown-heartbeatkeeper
Contributor
|
Important Review skippedDraft detected. Please check the settings in the CodeRabbit UI or the You can disable this status message by setting the ✨ Finishing touches🧪 Generate unit tests (beta)
Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out. Comment |
|
Please retry analysis of this Pull-Request directly on SonarQube Cloud |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
What
Why
How
Can this PR break any existing features. If yes, please list possible items. If no, please explain why. (PS: Admins do not merge the PR without this section filled)
Database Migrations
Env Config
Relevant Docs
Related Issues or PRs
Dependencies Versions
Notes on Testing
Screenshots
Checklist
I have read and understood the Contribution Guidelines.