def create_identity_edge( source_node_id: str, target_node_id: str, match_probability: float, source_record_ids: list[str], ) -> dict: return { "source": source_node_id, "target": target_node_id, "relation": "SAME_AS", "properties": { "match_probability": match_probability, "source_record_ids": source_record_ids, "resolved_at": datetime.utcnow().isoformat(), "resolver": "splink-3", "review_status": "auto" if match_probability >= 0.90 else "pending", } }