Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion m_flow/adapters/vector/chromadb/ChromaDBAdapter.py
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ def _deserialize_from_chroma(data: dict) -> dict:
deferred_dict = []
deferred_list = []

for key in data.keys():
for key in data:
if key.endswith("__dict"):
deferred_dict.append(key)
elif key.endswith("__list"):
Expand Down
4 changes: 2 additions & 2 deletions m_flow/retrieval/episodic/bundle_search.py
Original file line number Diff line number Diff line change
Expand Up @@ -449,7 +449,7 @@ async def _two_phase_projection(

# Step 2: Expand neighbors
ids_1_set = set(relevant_ids)
neighbor_ids = [nid for nid in fragment_1.nodes.keys() if nid not in ids_1_set]
neighbor_ids = [nid for nid in fragment_1.nodes if nid not in ids_1_set]

# Priority for neighbor node types (lower = higher priority)
# Support both "Entity" (new) and "Entity" (legacy) type values
Expand Down Expand Up @@ -527,7 +527,7 @@ async def _two_phase_projection_with_stats(

# Step 2: Expand neighbors
ids_1_set = set(relevant_ids)
neighbor_ids = [nid for nid in fragment_1.nodes.keys() if nid not in ids_1_set]
neighbor_ids = [nid for nid in fragment_1.nodes if nid not in ids_1_set]

# Priority for neighbor node types (lower = higher priority)
# Support both "Entity" (new) and "Entity" (legacy) type values
Expand Down
2 changes: 1 addition & 1 deletion m_flow/retrieval/utils/procedural_bundle_search.py
Original file line number Diff line number Diff line change
Expand Up @@ -320,7 +320,7 @@ async def search_col(col: str):
if relevant_ids and frag1 and frag1.nodes:
# Step 2: expand neighbors
ids_1_set = set(relevant_ids)
neighbor_ids = [nid for nid in frag1.nodes.keys() if nid not in ids_1_set]
neighbor_ids = [nid for nid in frag1.nodes if nid not in ids_1_set]
TYPE_PRIO = {
"Procedure": 0,
"ProcedureStepPoint": 1,
Expand Down
2 changes: 1 addition & 1 deletion m_flow/tests/test_multi_tenancy.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@

def _get_first_dataset_id(memorize_output):
"""Extract the first dataset_id from memorize output dictionary."""
for ds_id in memorize_output.keys():
for ds_id in memorize_output:
return ds_id
return None

Expand Down
Loading