Chunk ID: bbdcf3 Wall time: 0.0003 seconds Process exited with code 0 Original token count: 200138 Output: Total output lines: 8245 src/webhooks/README.md:* **Event Publishing (`webhooks/events.py`):** Defines the event types and allows us to publish new events to the processing queue. src/webhooks/README.md:Note that the webhooks require the *deriver* process to be running to facilitate the delivery of the webhook. docs/v3/guides/discord.mdx:assistant = honcho_client.peer(id="assistant", config={"observe_me": False}) src/webhooks/events.py:from src.utils.queue_payload import create_webhook_payload src/webhooks/events.py: QUEUE_EMPTY = "queue.empty" src/webhooks/events.py: """Webhook event for when a queue becomes empty.""" src/webhooks/events.py: queue_type: str src/webhooks/events.py: observer: str | None = None src/webhooks/events.py: observed: str | None = None src/webhooks/events.py: Add a webhook event to our DB queue. src/webhooks/events.py: # It's stored directly on the queue item src/webhooks/events.py: queue_item = QueueItem( src/webhooks/events.py: db.add(queue_item) tests/routes/test_peers.py:def test_get_peer_representation_with_session( tests/routes/test_peers.py: """Test peer representation with session_id parameter""" tests/routes/test_peers.py: # Test representation scoped to session tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py: assert isinstance(data["representation"], str) tests/routes/test_peers.py:def test_get_peer_representation_global( tests/routes/test_peers.py: """Test peer representation without session_id (global representation)""" tests/routes/test_peers.py: # Test global representation (no session_id) tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py: assert isinstance(data["representation"], str) tests/routes/test_peers.py:def test_get_peer_representation_with_target( tests/routes/test_peers.py: """Test peer representation with target parameter""" tests/routes/test_peers.py: # Test representation of target from observer's perspective tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py: assert isinstance(data["representation"], str) tests/routes/test_peers.py:def test_get_peer_representation_with_search_query( tests/routes/test_peers.py: """Test peer representation with search_query parameter""" tests/routes/test_peers.py: # Test representation with semantic search query tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py:def test_get_peer_representation_with_search_top_k( tests/routes/test_peers.py: """Test peer representation with search_top_k parameter""" tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py:def test_get_peer_representation_with_search_max_distance( tests/routes/test_peers.py: """Test peer representation with search_max_distance parameter""" tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py:def test_get_peer_representation_with_include_most_frequent( tests/routes/test_peers.py: """Test peer representation with include_most_frequent parameter""" tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py:def test_get_peer_representation_with_max_observations( tests/routes/test_peers.py: """Test peer representation with max_observations parameter""" tests/routes/test_peers.py: # Test with various max_observations values tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: "max_observations": max_obs, tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py:def test_get_peer_representation_with_all_parameters( tests/routes/test_peers.py: """Test peer representation with all optional parameters""" tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: "max_observations": 30, tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py: assert isinstance(data["representation"], str) tests/routes/test_peers.py:def test_get_peer_representation_boundary_values( tests/routes/test_peers.py: """Test peer representation with boundary values for numeric parameters""" tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: "max_observations": 1, tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: "max_observations": 100, tests/routes/test_peers.py:def test_get_peer_representation_default_max_observations( tests/routes/test_peers.py: """Test that max_observations defaults to 25 when not provided""" tests/routes/test_peers.py: # Test without max_observations - should use default of 25 tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{test_peer.name}/representation", tests/routes/test_peers.py: assert "representation" in data tests/routes/test_peers.py:def test_get_peer_card(client: TestClient, sample_data: tuple[Workspace, Peer]): tests/routes/test_peers.py: test_workspace, observer_peer = sample_data tests/routes/test_peers.py: # Create a second peer (the target/observed peer) tests/routes/test_peers.py: # Test getting observer's own card (should return null initially) tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{observer_peer.name}/card" tests/routes/test_peers.py: assert data["peer_card"] is None tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{observer_peer.name}/card", tests/routes/test_peers.py: assert data["peer_card"] is None tests/routes/test_peers.py:async def test_get_peer_card_with_data( tests/routes/test_peers.py: test_workspace, observer_peer = sample_data tests/routes/test_peers.py: # Create a second peer (the target/observed peer) tests/routes/test_peers.py: # Set a self-card for the observer peer tests/routes/test_peers.py: await crud.set_peer_card( tests/routes/test_peers.py: observer=observer_peer.name, tests/routes/test_peers.py: observed=observer_peer.name, tests/routes/test_peers.py: # Set a card for the observer describing the target peer tests/routes/test_peers.py: await crud.set_peer_card( tests/routes/test_peers.py: observer=observer_peer.name, tests/routes/test_peers.py: observed=target_peer_name, tests/routes/test_peers.py: # Test getting observer's own card tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{observer_peer.name}/card" tests/routes/test_peers.py: assert data["peer_card"] == self_card_content tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{observer_peer.name}/card", tests/routes/test_peers.py: assert data["peer_card"] == target_card_content tests/routes/test_peers.py:def test_set_peer_card(client: TestClient, sample_data: tuple[Workspace, Peer]): tests/routes/test_peers.py: test_workspace, observer_peer = sample_data tests/routes/test_peers.py: # Set the observer's own card tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{observer_peer.name}/card", tests/routes/test_peers.py: json={"peer_card": self_card}, tests/routes/test_peers.py: assert data["peer_card"] == self_card tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{observer_peer.name}/card" tests/routes/test_peers.py: assert response.json()["peer_card"] == self_card tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{observer_peer.name}/card", tests/routes/test_peers.py: json={"peer_card": target_card}, tests/routes/test_peers.py: assert data["peer_card"] == target_card tests/routes/test_peers.py: f"/v3/workspaces/{test_workspace.name}/peers/{observer_peer.name}/card", tests/routes/test_peers.py: assert response.json()["peer_card"] == target_card src/webhooks/webhook_delivery.py:from src.utils.queue_payload import WebhookPayload docs/v3/guides/granola.mdx:4. Print a summary of what was transferred docs/v3/guides/granola.mdx:| Meeting summary | Message from note creator | Multi-person calls store the summary | docs/v3/guides/granola.mdx:Granola's transcript uses `Them:` for all non-creator speakers with no disambiguation — in a 4-person call, everyone else is just `Them:`. Rather than guess incorrectly, the script stores Granola's summary as your record of the meeting, with participants in metadata. docs/v3/guides/granola.mdx: f"{meeting_summary}", docs/v3/guides/granola.mdx: "mode": "summary", docs/v3/guides/granola.mdx:The summary is attributed to you because it's *your* record of what happened. Granola captured your notes from a meeting where those people were present. docs/v3/guides/granola.mdx:For each meeting, you choose the import mode: two-person (full attribution), summary, or skip. For multi-person calls that are actually 1:1s (extra participants listed but didn't speak), you can override the detection and select the actual speaker. docs/v3/guides/granola.mdx:Because meetings live in a standard Honcho workspace, you can enrich peer representations with data from other channels: docs/v3/guides/granola.mdx:| Missing transcripts | Free tier has no transcript access. The script falls back to summary content. | docs/v3/guides/granola.mdx: has_s = bool(extract_summary(m)) docs/v3/guides/granola.mdx: label = "transcript+summary" if has_t and has_s else "transcript only" if has_t else "summary only" if has_s else "basic only" docs/v3/guides/granola.mdx:def extract_summary(meeting: dict[str, Any]) -> str: docs/v3/guides/granola.mdx: """Extract best available summary text from meeting data.""" docs/v3/guides/granola.mdx: for key in ("summary", "notes", "note", "meeting_notes", "description"): docs/v3/guides/granola.mdx: for tag in ("summary", "notes"): docs/v3/guides/granola.mdx:def import_summary( docs/v3/guides/granola.mdx: """Import a meeting as a summary message.""" docs/v3/guides/granola.mdx: summary = extract_summary(meeting) docs/v3/guides/granola.mdx: if not summary: docs/v3/guides/granola.mdx: summary = str(parsed.get("transcript", "")) if isinstance(parsed, dict) else raw_t docs/v3/guides/granola.mdx: summary = raw_t docs/v3/guides/granola.mdx: summary = summary or "No content available" docs/v3/guides/granola.mdx: messages = build_messages(me_peer, header + summary, metadata, created_at) docs/v3/guides/granola.mdx: print(" -> Imported as summary") docs/v3/guides/granola.mdx: - "summary": import as a single summary message docs/v3/guides/granola.mdx: print(f" Content: {'summary available' if extract_summary(meeting) else 'metadata only'}") docs/v3/guides/granola.mdx: return ("summary", None) docs/v3/guides/granola.mdx: choice = input(" [Enter] summary / [2] 2-person / [k] skip: ").strip().lower() docs/v3/guides/granola.mdx: choice = input(" [Enter] summary / [2] 2-person / [k] skip: ").strip().lower() docs/v3/guides/granola.mdx: return ("summary", None) docs/v3/guides/granola.mdx: return ("summary", None) docs/v3/guides/granola.mdx: choice = input(" [Enter] summary / [k] skip: ").strip().lower() docs/v3/guides/granola.mdx: choice = input(" [Enter] summary / [k] skip: ").strip().lower() docs/v3/guides/granola.mdx: return ("summary", None) docs/v3/guides/granola.mdx: import_summary(honcho, session, me_peer_id, m, metadata, created_at) docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx:Verify config and connectivity. Scope with -w / -p to check workspace, peer, and queue health. docs/snippets/cli-commands.mdx:List, create, chat with, search, and manage peers and their representations. docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: Whether Honcho will form a representation of this peer. Negate with `--no-observe-me`. docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx:Get the formatted representation for a peer. docs/snippets/cli-commands.mdx:honcho peer representation [] docs/snippets/cli-commands.mdx: Target peer to get representation about. docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: Include summary. Negate with `--no-summary`. docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx:Get the representation of a peer within a session. docs/snippets/cli-commands.mdx:honcho session representation [] docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx:Get queue processing status. docs/snippets/cli-commands.mdx:honcho workspace queue-status docs/snippets/cli-commands.mdx: docs/snippets/cli-commands.mdx: Filter by observer peer. src/startup/__init__.py:"""Startup-time validators that gate API/deriver boot.""" src/startup/__init__.py:from src.startup.embedding_validator import ( src/startup/__init__.py: validate_embedding_schema, src/startup/__init__.py:__all__ = ("StartupValidationError", "validate_embedding_schema") tests/routes/test_files.py: configuration = {"skip_deriver": True, "custom_flag": "test"} tests/routes/test_files.py: configuration = {"skip_deriver": False, "test_mode": True} src/startup/embedding_validator.py:"""Startup validator for the embedding pipeline. src/startup/embedding_validator.py:ones. Full enumeration is available via `uv run python scripts/configure_embeddings.py --report`. src/startup/embedding_validator.py:_EMBEDDING_TABLES: tuple[str, ...] = ("documents", "message_embeddings") src/startup/embedding_validator.py: """Raised when the embedding configuration cannot be reconciled with the src/startup/embedding_validator.py: queue task is processed. src/startup/embedding_validator.py:async def validate_embedding_schema( src/startup/embedding_validator.py: """Validate that the embedding schema matches the configured dimension. src/startup/embedding_validator.py: Run after the DB pool is initialized and before the embedding client is src/startup/embedding_validator.py: Returns a mapping of table name -> raw ``atttypmod`` for the embedding src/startup/embedding_validator.py: f"could not validate embedding schema: {underlying}" src/startup/embedding_validator.py: raise StartupValidationError("embedding schema introspection did not run") src/startup/embedding_validator.py: AND a.attname = 'embedding' src/startup/embedding_validator.py: listing = ", ".join(sorted(f"{schema}.{t}.embedding" for t in missing)) src/startup/embedding_validator.py: f"{schema}.{table}.embedding has no declared vector dimension" src/startup/embedding_validator.py: + " `uv run python scripts/configure_embeddings.py`." src/startup/embedding_validator.py: f"{schema}.{table}.embedding dim ({actual}) does not match" src/startup/embedding_validator.py: + " `uv run python scripts/configure_embeddings.py`" src/startup/embedding_validator.py: - Document namespaces — one per existing ``(workspace, observer, observed)`` src/startup/embedding_validator.py: ``configure_embeddings --report`` for full enumeration when a hard src/startup/embedding_validator.py: for workspace_name, observer, observed in collection_keys: src/startup/embedding_validator.py: observer=observer, src/startup/embedding_validator.py: observed=observed, src/startup/embedding_validator.py: + " `uv run python scripts/configure_embeddings.py --report`." src/startup/embedding_validator.py: """Pull up to ``limit`` ``(workspace_name, observer, observed)`` triples, src/startup/embedding_validator.py: select(Collection.workspace_name, Collection.observer, Collection.observed) docs/v3/guides/migrations/mem0.mdx:**Superior Performance** - Higher accuracy on memory retrieval benchmarks with faster inference times (more details soon!). docs/v3/guides/migrations/mem0.mdx:**Advanced Multi-Peer Sessions** - Honcho offers configurable observation settings (who builds memories about whom), representation-based queries between participants, and first-class peer objects. docs/v3/guides/migrations/mem0.mdx:For the best results, we recommend importing your raw messages directly into Honcho. This gives Honcho the full context to build rich, accurate representations and enables features like session summaries. docs/v3/guides/migrations/mem0.mdx:That's it! The user's Mem0 memories are now searchable in Honcho as conclusions. For richer representations with deductive reasoning and session summaries, consider importing your raw messages as described in the [Step-by-Step Migration](#step-by-step-migration) section. docs/v3/guides/migrations/mem0.mdx:Importing raw user messages gives Honcho the full conversational context to build the most accurate representations. We recommend using a data structure that preserves the session and peer structure. docs/v3/guides/migrations/mem0.mdx: Learn more about inference-powered queries docs/v3/guides/migrations/mem0.mdx:| `session.representation(peer)` | Cached psychological analysis (mental state, intentions) | Real-time adaptation | docs/v3/guides/integrations/mcp.mdx:**Peers** — `create_peer`, `list_peers`, `chat`, `get_peer_card`, `set_peer_card`, `get_peer_context`, `get_representation` docs/v3/guides/integrations/mcp.mdx:**System** — `schedule_dream`, `get_queue_status` docs/v3/guides/integrations/mcp.mdx:On the first conversation there won't be much — but after a few exchanges, Honcho's background reasoning will start building a representation of you. Ask again after a couple of conversations and you'll see the difference. docs/v3/documentation/reference/cli.mdx: honcho conclusion list --observer --json docs/v3/documentation/reference/cli.mdx: honcho conclusion search "topic" --…190138 tokens truncated…s/deriver/test_deriver_processing.py: legacy_observer = legacy_payload.get("observer") tests/deriver/test_deriver_processing.py: observers = [legacy_observer] if legacy_observer else [] tests/deriver/test_deriver_processing.py: assert observers == ["peer_observer"] tests/deriver/test_deriver_processing.py: def test_new_payload_observers_list_used_directly(self): tests/deriver/test_deriver_processing.py: """Test that new payloads with 'observers' list are used directly.""" tests/deriver/test_deriver_processing.py: "observers": ["peer1", "peer2"], tests/deriver/test_deriver_processing.py: "observed": "peer3", tests/deriver/test_deriver_processing.py: "task_type": "representation", tests/deriver/test_deriver_processing.py: observers = new_payload.get("observers") tests/deriver/test_deriver_processing.py: if observers is None: tests/deriver/test_deriver_processing.py: legacy_observer = new_payload.get("observer") tests/deriver/test_deriver_processing.py: observers = [legacy_observer] if legacy_observer else [] tests/deriver/test_deriver_processing.py: assert observers == ["peer1", "peer2"] tests/deriver/test_deriver_processing.py: def test_empty_payload_results_in_empty_observers_list(self): tests/deriver/test_deriver_processing.py: """Test that payloads with neither observer nor observers return empty list.""" tests/deriver/test_deriver_processing.py: "observed": "peer_observed", tests/deriver/test_deriver_processing.py: "task_type": "representation", tests/deriver/test_deriver_processing.py: observers = empty_payload.get("observers") tests/deriver/test_deriver_processing.py: if observers is None: tests/deriver/test_deriver_processing.py: legacy_observer = empty_payload.get("observer") tests/deriver/test_deriver_processing.py: observers = [legacy_observer] if legacy_observer else [] tests/deriver/test_deriver_processing.py: assert observers == [] tests/deriver/test_deriver_processing.py: # async def test_representation_batch_uses_earliest_cutoff( tests/deriver/test_deriver_processing.py: # "src.deriver.deriver.summarizer.get_session_context_formatted", tests/deriver/test_deriver_processing.py: # # Provide a stub working representation so embedding lookups are skipped. tests/deriver/test_deriver_processing.py: # "src.crud.get_working_representation", tests/deriver/test_deriver_processing.py: # "src.deriver.deriver.CertaintyReasoner.reason", tests/deriver/test_deriver_processing.py: # await process_representation_tasks_batch( tests/deriver/test_deriver_processing.py: # observer=alice.name, tests/deriver/test_deriver_processing.py: # observed=alice.name, tests/crud/test_representation_manager.py:from src.crud.representation import RepresentationManager tests/crud/test_representation_manager.py:from src.utils.representation import ( tests/crud/test_representation_manager.py:def _saved_observations(mock_save: AsyncMock): tests/crud/test_representation_manager.py: if "all_observations" in call.kwargs: tests/crud/test_representation_manager.py: return call.kwargs["all_observations"] tests/crud/test_representation_manager.py: raise AssertionError("missing all_observations in await args") tests/crud/test_representation_manager.py: observer=test_peer.name, tests/crud/test_representation_manager.py: observed=test_peer2.name, tests/crud/test_representation_manager.py: observer=test_peer.name, tests/crud/test_representation_manager.py: observed=test_peer2.name, tests/crud/test_representation_manager.py: observer=test_peer.name, tests/crud/test_representation_manager.py: observed=test_peer2.name, tests/crud/test_representation_manager.py: observer=test_peer.name, tests/crud/test_representation_manager.py: observed=test_peer2.name, tests/crud/test_representation_manager.py: async def test_query_documents_most_derived_excludes_soft_deleted( tests/crud/test_representation_manager.py: """Soft-deleted documents must not appear in the most-derived query.""" tests/crud/test_representation_manager.py: # Create two documents with different times_derived tests/crud/test_representation_manager.py: observer=test_peer.name, tests/crud/test_representation_manager.py: observed=test_peer2.name, tests/crud/test_representation_manager.py: times_derived=5, tests/crud/test_representation_manager.py: observer=test_peer.name, tests/crud/test_representation_manager.py: observed=test_peer2.name, tests/crud/test_representation_manager.py: content="Deleted high-derived observation", tests/crud/test_representation_manager.py: times_derived=100, tests/crud/test_representation_manager.py: # Soft-delete the high-derived one tests/crud/test_representation_manager.py: results = await manager._query_documents_most_derived(db_session, top_k=10) # pyright: ignore[reportPrivateUsage] tests/crud/test_representation_manager.py: async def test_save_representation_filters_blank_observations_before_embedding( tests/crud/test_representation_manager.py: observer="observer", tests/crud/test_representation_manager.py: observed="observed", tests/crud/test_representation_manager.py: representation = Representation( tests/crud/test_representation_manager.py: patch("src.crud.representation.tracked_db", _fake_tracked_db), tests/crud/test_representation_manager.py: "src.crud.representation.embedding_client.simple_batch_embed", tests/crud/test_representation_manager.py: "_save_representation_internal", tests/crud/test_representation_manager.py: saved = await manager.save_representation( tests/crud/test_representation_manager.py: representation, tests/crud/test_representation_manager.py: dream=SimpleNamespace(enabled=False) tests/crud/test_representation_manager.py: saved_observations = _saved_observations(mock_save) tests/crud/test_representation_manager.py: assert len(saved_observations) == 1 tests/crud/test_representation_manager.py: assert saved_observations[0].content == "useful observation" tests/crud/test_representation_manager.py: async def test_save_representation_filters_blank_deductive_observations(self): tests/crud/test_representation_manager.py: observer="observer", tests/crud/test_representation_manager.py: observed="observed", tests/crud/test_representation_manager.py: representation = Representation( tests/crud/test_representation_manager.py: patch("src.crud.representation.tracked_db", _fake_tracked_db), tests/crud/test_representation_manager.py: "src.crud.representation.embedding_client.simple_batch_embed", tests/crud/test_representation_manager.py: "_save_representation_internal", tests/crud/test_representation_manager.py: saved = await manager.save_representation( tests/crud/test_representation_manager.py: representation, tests/crud/test_representation_manager.py: dream=SimpleNamespace(enabled=False) tests/crud/test_representation_manager.py: saved_observations = _saved_observations(mock_save) tests/crud/test_representation_manager.py: assert len(saved_observations) == 1 tests/crud/test_representation_manager.py: assert isinstance(saved_observations[0], DeductiveObservation) tests/crud/test_representation_manager.py: assert saved_observations[0].conclusion == "inferred conclusion" tests/crud/test_representation_manager.py: async def test_save_representation_skips_all_blank_observations(self): tests/crud/test_representation_manager.py: observer="observer", tests/crud/test_representation_manager.py: observed="observed", tests/crud/test_representation_manager.py: representation = Representation( tests/crud/test_representation_manager.py: patch("src.crud.representation.tracked_db", _fake_tracked_db), tests/crud/test_representation_manager.py: "src.crud.representation.embedding_client.simple_batch_embed", tests/crud/test_representation_manager.py: "_save_representation_internal", tests/crud/test_representation_manager.py: saved = await manager.save_representation( tests/crud/test_representation_manager.py: representation, tests/crud/test_representation_manager.py: dream=SimpleNamespace(enabled=False) tests/crud/test_peer_card.py:from src.crud.peer_card import construct_peer_card_label, get_peer_card, set_peer_card tests/crud/test_peer_card.py:async def test_peer_card_get_set_roundtrip( tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer.name, observed=peer.name tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer.name, tests/crud/test_peer_card.py: observed=peer.name, tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer.name, observed=peer.name tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, value_2, observer=peer.name, observed=peer.name tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer.name, observed=peer.name tests/crud/test_peer_card.py:async def test_get_peer_card_missing_peer_raises( tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: observer="missing-peer", tests/crud/test_peer_card.py: observed="missing-peer", tests/crud/test_peer_card.py:async def test_get_peer_card_missing_workspace_raises( tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: observer=peer.name, tests/crud/test_peer_card.py: observed=peer.name, tests/crud/test_peer_card.py:async def test_peer_card_empty_list( tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer.name, tests/crud/test_peer_card.py: observed=peer.name, tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer.name, observed=peer.name tests/crud/test_peer_card.py:async def test_peer_card_multiple_lines( tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer.name, tests/crud/test_peer_card.py: observed=peer.name, tests/crud/test_peer_card.py: result = await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer.name, observed=peer.name tests/crud/test_peer_card.py:async def test_peer_card_different_observer_observed( tests/crud/test_peer_card.py: """Test peer card with different observer and observed peers.""" tests/crud/test_peer_card.py: # Peer1 observes peer2 tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer1.name, tests/crud/test_peer_card.py: observed=peer2.name, tests/crud/test_peer_card.py: # Peer2 observes peer1 tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer2.name, tests/crud/test_peer_card.py: observed=peer1.name, tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer1.name, observed=peer2.name tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer2.name, observed=peer1.name tests/crud/test_peer_card.py:async def test_peer_card_self_and_other_observations( tests/crud/test_peer_card.py: """Test that a peer can have both a self-observation and observations of others.""" tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer1.name, tests/crud/test_peer_card.py: observed=peer1.name, tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer1.name, tests/crud/test_peer_card.py: observed=peer2.name, tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer1.name, observed=peer1.name tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer1.name, observed=peer2.name tests/crud/test_peer_card.py:async def test_peer_card_multiple_observers_same_observed( tests/crud/test_peer_card.py: """Test that multiple peers can observe the same peer with different cards.""" tests/crud/test_peer_card.py: # Both peer2 and peer3 observe peer1 tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer2.name, tests/crud/test_peer_card.py: observed=peer1.name, tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer3.name, tests/crud/test_peer_card.py: observed=peer1.name, tests/crud/test_peer_card.py: # Each observer should have their own independent card tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer2.name, observed=peer1.name tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer3.name, observed=peer1.name tests/crud/test_peer_card.py:async def test_peer_card_update_does_not_affect_others( tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer1.name, tests/crud/test_peer_card.py: observed=peer1.name, tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer1.name, tests/crud/test_peer_card.py: observed=peer2.name, tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer1.name, tests/crud/test_peer_card.py: observed=peer1.name, tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer1.name, observed=peer1.name tests/crud/test_peer_card.py: await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer1.name, observed=peer2.name tests/crud/test_peer_card.py:async def test_peer_card_special_characters( tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer.name, tests/crud/test_peer_card.py: observed=peer.name, tests/crud/test_peer_card.py: result = await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer.name, observed=peer.name tests/crud/test_peer_card.py:async def test_peer_card_large_content( tests/crud/test_peer_card.py: # Create a large peer card with many observations tests/crud/test_peer_card.py: await set_peer_card( tests/crud/test_peer_card.py: observer=peer.name, tests/crud/test_peer_card.py: observed=peer.name, tests/crud/test_peer_card.py: result = await get_peer_card( tests/crud/test_peer_card.py: db_session, workspace.name, observer=peer.name, observed=peer.name tests/crud/test_peer_card.py: assert construct_peer_card_label(observer="a", observed="a") == "peer_card" tests/crud/test_peer_card.py: assert construct_peer_card_label(observer="a", observed="b") == "b_peer_card" tests/crud/test_peer_card.py:def test_construct_peer_card_label_with_special_chars(): tests/crud/test_peer_card.py: construct_peer_card_label(observer="peer-1", observed="peer-2") tests/crud/test_peer_card.py: == "peer-2_peer_card" tests/crud/test_peer_card.py: construct_peer_card_label(observer="peer_1", observed="peer_2") tests/crud/test_peer_card.py: == "peer_2_peer_card" tests/crud/test_peer_card.py: # Test with same observer and observed with special chars tests/crud/test_peer_card.py: construct_peer_card_label(observer="peer-1", observed="peer-1") == "peer_card" tests/crud/test_peer_card.py:def test_construct_peer_card_label_edge_cases(): tests/crud/test_peer_card.py: assert construct_peer_card_label(observer="", observed="") == "peer_card" tests/crud/test_peer_card.py: assert construct_peer_card_label(observer="a", observed="") == "_peer_card" tests/crud/test_peer_card.py: construct_peer_card_label(observer=long_name, observed=long_name) == "peer_card" tests/crud/test_peer_card.py: construct_peer_card_label(observer="a", observed=long_name) tests/crud/test_peer_card.py: == f"{long_name}_peer_card" tests/crud/test_workspace.py: observer=test_peer.name, tests/crud/test_workspace.py: observed=test_peer.name, tests/crud/test_workspace.py: observer=test_peer.name, tests/crud/test_workspace.py: observed=test_peer.name, tests/crud/test_workspace.py: observer=test_peer.name, tests/crud/test_workspace.py: observed=test_peer.name, tests/crud/test_workspace.py: async def test_delete_workspace_cascade_queue_items( tests/crud/test_workspace.py: """Test that deleting a workspace cascades to delete queue items""" tests/crud/test_workspace.py: # Create queue item with work_unit_key containing workspace name tests/crud/test_workspace.py: queue_item = models.QueueItem( tests/crud/test_workspace.py: work_unit_key=[REDACTED] tests/crud/test_workspace.py: task_type="representation", tests/crud/test_workspace.py: db_session.add(queue_item) tests/crud/test_workspace.py: # Verify queue item exists tests/crud/test_workspace.py: queue_items = result.scalars().all() tests/crud/test_workspace.py: assert len(queue_items) == 1 tests/crud/test_workspace.py: # Verify queue item is deleted tests/crud/test_workspace.py: queue_items = result.scalars().all() tests/crud/test_workspace.py: assert len(queue_items) == 0 tests/crud/test_workspace.py: async def test_delete_workspace_cascade_active_queue_sessions( tests/crud/test_workspace.py: """Test that deleting a workspace cascades to delete active queue sessions""" tests/crud/test_workspace.py: # Create active queue session with work_unit_key containing workspace name tests/crud/test_workspace.py: active_queue = models.ActiveQueueSession( tests/crud/test_workspace.py: work_unit_key=[REDACTED] tests/crud/test_workspace.py: db_session.add(active_queue) tests/crud/test_workspace.py: # Verify active queue session exists tests/crud/test_workspace.py: active_queues = result.scalars().all() tests/crud/test_workspace.py: assert len(active_queues) == 1 tests/crud/test_workspace.py: # Verify active queue session is deleted tests/crud/test_workspace.py: active_queues = result.scalars().all() tests/crud/test_workspace.py: assert len(active_queues) == 0 tests/crud/test_workspace.py: observer=test_peer.name, tests/crud/test_workspace.py: observed=peer2.name, tests/crud/test_workspace.py: observer=test_peer.name, tests/crud/test_workspace.py: observed=peer2.name,