Search Operations¶

Search query operations.

async shared.database.operations.search.create_search_query(*, task_id, query_text, rationale=None, categories=None, time_from=None, time_to=None, status='active')[source]¶

Create a new search query.

Parameters:

task_id (int) – Task ID
query_text (str) – Search query text
rationale (Optional[str]) – Query rationale
categories (Optional[List[str]]) – Search categories
time_from (Optional[str]) – Time from
time_to (Optional[str]) – Time to
status (str) – Query status

Return type:

SearchQuery

Returns:

SearchQuery instance

async shared.database.operations.search.list_active_queries_for_task(task_id)[source]¶

List active search queries for a task.

Parameters:: task_id (int) – Task ID
Return type:: List[SearchQuery]
Returns:: List of SearchQuery instances

async shared.database.operations.search.record_finding(task_id, paper_id, relevance, summary)[source]¶

Record a research finding.

Parameters:

task_id (int) – Task ID
paper_id (int) – Paper ID
relevance (float) – Relevance score
summary (Optional[str]) – Finding summary

Return type:

Finding

Returns:

Finding instance

async shared.database.operations.search.update_search_query_stats(query_id, success_increment=0)[source]¶

Update search query statistics.

Parameters:

query_id (int) – Query ID
success_increment (int) – Success count increment

Return type:

None