Skip to content

Conversation

@aritra-os
Copy link

[2026NewYearChallenge] Event-Driven Orchestration Implementation (Track B)

Summary
I have successfully implemented a decoupled, event-driven architecture for MemU as requested in Issue #190. This architecture offloads heavy memory processing to background Celery workers, preventing the main API from blocking.

Key Features Implemented:

  • Event Hooks: Implemented EventManager (Pub/Sub pattern) to trigger signals like on_memory_saved.
  • Dispatcher: Created CeleryDispatcher to route these events to Redis/Celery.
  • Robust Architecture: Implemented a Self-Registration Pattern for the Dispatcher to ensure reliable event subscription at startup.
  • Async Worker: Added a production-ready worker.py entry point.
  • Security (Bonus): Added SSRF protection and Input Validation to the worker (src/memu/task_utils) to ensure production readiness.

Verification:

  • Demo: examples/example_4_event_driven_orchestration.py confirms end-to-end event delivery.
  • Reliability: 15/16 Unit tests passed (tests/test_event_driven.py).
  • Security: 26/26 Security tests passed (tests/test_task_validation.py).

@aritra-os aritra-os changed the title [2026NewYearChallenge] Event-Driven Orchestration with Celery Integration (Track B) feat: [2026NewYearChallenge] Event-Driven Orchestration (Track B) Jan 11, 2026
@Jununn
Copy link
Contributor

Jununn commented Jan 13, 2026

Hi, the build for this PR is not passing yet. Please make the necessary updates, and we’ll review again after that. Thanks! @Rain-09x16

@aritra-os
Copy link
Author

Hi, the build for this PR is not passing yet. Please make the necessary updates, and we’ll review again after that. Thanks! @Rain-09x16

fixed can you run the build

theomart pushed a commit to theomart/memU that referenced this pull request Jan 15, 2026
Analyzed the MemU repository to document:
- Memory types (Profile, Event, Knowledge, Behavior, Skill)
- Three-layer hierarchical architecture (Resource → Item → Category)
- Storage backends (InMemory, SQLite, PostgreSQL)
- Memorize and Retrieve pipelines
- Key architectural patterns

GitHub activity analysis includes:
- Hot PRs (NevaMind-AI#242 Engram integration, NevaMind-AI#218 Event-Driven Architecture)
- Community trends and contribution opportunities
- Recent merged features (workflow interceptors, clear memory)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants