@@ -437,7 +437,7 @@ def breathe(
437
437
438
438
439
439
def find_similar_groups (
440
- conn : kuzu . Connection ,
440
+ conn ,
441
441
fact : str , # Ensure fact is passed as a string
442
442
model : str = "llama3.2" ,
443
443
provider : str = "ollama" ,
@@ -556,7 +556,7 @@ def assign_to_groups(
556
556
return response ["response" ]
557
557
558
558
559
- def insert_fact (conn : kuzu . Connection , fact : str , path : str ) -> bool :
559
+ def insert_fact (conn , fact : str , path : str ) -> bool :
560
560
"""Insert a fact into the database with robust error handling"""
561
561
if conn is None :
562
562
print ("Cannot insert fact: database connection is None" )
@@ -613,7 +613,7 @@ def insert_fact(conn: kuzu.Connection, fact: str, path: str) -> bool:
613
613
return False
614
614
615
615
616
- def assign_fact_to_group (conn : kuzu . Connection , fact : str , group : str ) -> bool :
616
+ def assign_fact_to_group (conn , fact : str , group : str ) -> bool :
617
617
"""Create a relationship between a fact and a group with robust error handling"""
618
618
if conn is None :
619
619
print ("Cannot assign fact to group: database connection is None" )
@@ -671,7 +671,7 @@ def assign_fact_to_group(conn: kuzu.Connection, fact: str, group: str) -> bool:
671
671
672
672
673
673
def save_facts_to_db (
674
- conn : kuzu . Connection , facts : List [str ], path : str , batch_size : int
674
+ conn , facts : List [str ], path : str , batch_size : int
675
675
):
676
676
"""Save a list of facts to the database in batches"""
677
677
for i in range (0 , len (facts ), batch_size ):
0 commit comments