science_live.pipeline.result_processor

Contents

`science_live.pipeline.result_processor`#

ResultProcessor - Process raw SPARQL results into structured format

Module Contents#

Classes#

ResultProcessor

Process raw SPARQL results into structured format

API#

class science_live.pipeline.result_processor.ResultProcessor(config: Dict[str, Any] = None)[source]#

Process raw SPARQL results into structured format

Initialization

async process(query_results: science_live.pipeline.common.QueryResults, generated_statements: science_live.pipeline.common.GeneratedStatements, context: science_live.pipeline.common.ProcessingContext) → science_live.pipeline.common.ProcessedResults[source]#: Process raw SPARQL results

async _process_single_result(raw_result: Dict[str, Any], generated_statements: science_live.pipeline.common.GeneratedStatements) → Optional[science_live.pipeline.common.StructuredResult][source]#: Process a single raw SPARQL result

_match_to_rosetta_statement(raw_result: Dict[str, Any], generated_statements: science_live.pipeline.common.GeneratedStatements) → Optional[science_live.pipeline.common.RosettaStatement][source]#: Try to match raw result back to original Rosetta statement

_classify_result_type(raw_result: Dict[str, Any]) → str[source]#: Classify the type of result

_assess_completeness(raw_result: Dict[str, Any]) → float[source]#: Assess how complete the result is

_group_results(results: List[science_live.pipeline.common.StructuredResult]) → Dict[str, List[science_live.pipeline.common.StructuredResult]][source]#: Group results by various criteria

_calculate_processing_confidence(structured_results: List[science_live.pipeline.common.StructuredResult], query_results: science_live.pipeline.common.QueryResults) → float[source]#: Calculate confidence in result processing