@@ -45,36 +45,39 @@ def run_fact_check_pipeline(state):
4545 result = run_claim_extractor_sdk (state )
4646
4747 if state .get ("status" ) != "success" :
48- logger .error ("❌ Claim extraction failed." )
48+ logger .error ("Claim extraction failed." )
4949 return [], "Claim extraction failed."
5050
5151 # Step 1: Extract claims
5252 raw_output = result .get ("verifiable_claims" , "" )
5353 claims = re .findall (r"^[\*\-•]\s+(.*)" , raw_output , re .MULTILINE )
5454 claims = [claim .strip () for claim in claims if claim .strip ()]
55- logger .info (f"🧠 Extracted claims: { claims } " )
55+ logger .info (f"Extracted claims: { claims } " )
5656
5757 if not claims :
5858 return [], "No verifiable claims found."
5959
6060 # Step 2: Search each claim with polite delay
6161 search_results = []
6262 for claim in claims :
63- logger .info (f"\n 🔍 Searching for claim: { claim } " )
63+ logger .info (f"Searching for claim: { claim } " )
6464 try :
6565 results = search_google (claim )
6666 if results :
6767 results [0 ]["claim" ] = claim
6868 search_results .append (results [0 ])
69- logger .info (f"✅ Found result: { results [0 ]['title' ]} " )
69+ logger .info (f"Found result: { results [0 ]['title' ]} " )
7070 else :
71- logger .warning (f"⚠️ No search result for: { claim } " )
71+ logger .warning (f"No search result for: { claim } " )
7272 except Exception as e :
73- logger .error (f"❌ Search failed for: { claim } -> { e } " )
73+ logger .error (f"Search failed for: { claim } -> { e } " )
7474
7575 if not search_results :
76+ logger .error ("All claim searches failed or returned no results." )
7677 return [], "All claim searches failed or returned no results."
7778
7879 # Step 3: Verify facts using LLM
80+ logger .info (f"Verifying { len (search_results )} claims using LLM..." )
7981 final = run_fact_verifier_sdk (search_results )
82+ logger .info ("Fact-checking pipeline completed successfully." )
8083 return final .get ("verifications" , []), None
0 commit comments