FeaturedApplied AI · healthcare● Hackathon winner
★ OpenAI San Francisco Hackathon · Winner
PulseScribe — Ambient Clinical Scribe
Real-time ambient scribe for clinical conversations. WebSocket speech-to-text for live transcription, incremental SOAP note generation, and a Risk Sentinel module that surfaces clinical risks with transcript-backed evidence. The LLM layer is deliberately non-blocking: if generation fails, transcription stays alive, because a crash must never interrupt a doctor mid-conversation.
PythonFastAPINext.jsWebSocketsLLM
Distributed systems● Public repo
RaftKV — Distributed Key-Value Store
Raft consensus implemented from scratch in C++20 — no etcd/raft, no NuRaft. Leader election, log replication, and crash recovery across a multi-node cluster, with linearizable reads via ReadIndex and leader-lease paths rather than routing every read through the log. The consensus core is deliberately pure: no sockets, no threads, no clock reads, so every scenario replays from a seed.
316 / 316
tests passing, incl. 250 randomized safety seeds
C++20gRPCProtocol BuffersCMake
Distributed systems● Public repo
Distributed Task Queue & Workflow Engine
Background-job engine on a pluggable broker interface with three implementations — Redis Streams, Kafka, RabbitMQ — so the same workload is benchmarked across brokers rather than assumed to behave alike. Exactly-once effect — not exactly-once delivery — via at-least-once delivery plus idempotent commit plus fencing tokens that stop a partitioned worker from writing after its lease is reassigned.
118,831/s
sustained 31 min · 221M events · zero failed · p99 17 ms
PythonRedis StreamsKafkaPostgreSQLgRPC
AI engineering● Repo private
GraphRAG Multi-Agent Reasoning Engine
Retrieval system that parses documents into a semantic knowledge graph instead of treating retrieval as top-k similarity. Every node and edge carries provenance back to its source span, so an answer traces to the exact text it came from. A query router picks graph traversal, vector search, or both, then fuses with Reciprocal Rank Fusion; a critique step can reject an answer and force re-retrieval, and abstention is a permitted outcome rather than a forced guess.
Neo4jLlamaIndexLangGraphMilvusDSPy
AI engineering● Public repo
Self-Healing Code-Generation Agent
Agent that closes the loop on its own failures: writes code, runs it in a per-run Docker sandbox, parses the traceback back into structured context, and iterates until tests pass. Sandboxing is the load-bearing part — no network, read-only root, dropped capabilities, and CPU/memory/process/wall-clock limits, because an agent running code it just wrote needs a containment boundary rather than a promise of good behaviour.
19 escape tests
fork bombs, rm -rf /, outbound HTTP, privilege escalation
PythonDocker SDKOpenRouterDSPypytest
Backend · inference● Public repo
LLM Inference Gateway
Gateway between client apps and self-hosted models: semantic caching, backend routing, rate limiting, and per-tenant accounting behind one OpenAI-compatible surface. The committed threshold sweep is a negative result, and it is the most useful thing in the repo — against adversarial near-misses (Australia vs. Austria, enable vs. disable), no single similarity threshold makes the cache both useful and safe.
47.5% hit / 45% false-hit
at τ=0.86 — why embedding similarity ≠ semantic equivalence
FastAPIRedispgvectorvLLMTerraform
Backend · streaming● Public repo
Stateful Agentic Orchestrator
Orchestration backend where a run outlives any single client connection and a reconnecting client recovers exactly what it missed. Every run appends to an immutable events table under a gap-free per-run sequence number allocated inside the run transaction — a hole in the sequence is indistinguishable from lost reasoning. Cross-instance fan-out via PostgreSQL LISTEN/NOTIFY over a transactional outbox, so no sticky sessions.
Zero sequence gaps
at 50 / 150 / 500 / 1000 concurrent · 289 reconnects, all clean
FastAPIWebSocketsPostgreSQLAWS SQSTerraform
Forward deployed● Public repo
Enterprise Helpdesk Agent Studio
Action-taking helpdesk agent that drafts operational changes — ticket updates, status transitions, refunds — for a human to confirm before anything executes. The design commitment is a hard read/write split: the agent’s own tool surface is read-only over MCP, and every write goes through a separate executor that only acts on an HMAC-signed, single-use, expiring approval token. An agent with write credentials and a review step it can bypass is not human-in-the-loop.
Next.jsFastAPISlack + Jira OAuthKeycloakHelm
Forward deployed · data● Public repo
Unstructured Data Ingestion Pipeline
Two tiers for turning messy client documents into strictly conformed data: an interactive tier for onboarding one client’s files, where an operator reviews every extracted field against its source span, and a batch Medallion lakehouse — Bronze, Silver, Gold on Delta Lake — for processing a corpus at volume. Per-field confidence is surfaced so review effort goes where the extractor is unsure.
PySparkDelta LakeAirflowdbtKafka
Applied AI · healthcare● Live demo
Clinical RAG Pipeline
Clinical retrieval-augmented generation pipeline combining text and imaging embeddings for case-aware diagnostic insights. AstraDB for vector retrieval, MedLLaMA for grounded report generation.
PythonAstraDBLangChainPostgreSQL