science_live.pipeline.query_executor

Contents

`science_live.pipeline.query_executor`#

QueryExecutor - Execute SPARQL against nanopub endpoints

Module Contents#

Classes#

QueryExecutor

Execute SPARQL against nanopub endpoints

API#

class science_live.pipeline.query_executor.QueryExecutor(endpoint_manager, config: Dict[str, Any] = None)[source]#

Execute SPARQL against nanopub endpoints

Initialization

async execute(generated_queries: science_live.pipeline.common.GeneratedQueries, context: science_live.pipeline.common.ProcessingContext) → science_live.pipeline.common.QueryResults[source]#: Execute SPARQL queries with fallback strategy

async _execute_single_query(sparql_query: science_live.pipeline.common.SPARQLQuery, context: science_live.pipeline.common.ProcessingContext) → science_live.pipeline.common.QueryResults[source]#: Execute a single SPARQL query