parameterTypecallsrdfs:labelparameterextendshasParametercreatesimplementationDetailcallsIndirectlyimportsOther subjects in dontopedia point AT this entity as a value. These are inverse relationships — e.g. “X motherOf this subject” — and answer questions the forward facts can't. Grouped by predicate.
returnedByReturned by(2)ex:reformulated_queriesex:resultsusedInUsed in(2)ex:len_functionex:range_functionargumentArgument(1)ex:asyncio.runassignmentAssignment(1)ex:reformulated_queriesattachedToAttached to(1)ex:comment_5calledByCalled by(1)ex:reformulate_querycalledByFunctionCalled by Function(1)ex:process_queriescalledWithCalled With(1)ex:asyncio.runcallsCalls(1)ex:test_implementationcallsFunctionCalls Function(1)ex:asyncio.runconceptConcept(1)ex:concurrentExecutioncontainsFunctionContains Function(1)ex:code_snippetdescribesDescribes(1)ex:comment_2hasFunctionHas Function(1)ex:source_documenthasMethodHas Method(1)ex:query-rewriterprocessedByProcessed by(1)ex:queriesThe long tail: predicates that appear too rarely to warrant their own section. Filter or scroll to find a specific one. Each row links to its source.
| Predicate | Value | Ref |
|---|---|---|
| Batch Size | 100 | [3] |
| Batch Size | 100 | [4] |
| Passes As Argument | Test Queries Variable | [8] |
| Parameter Count | 2 | [4] |
| Called by | Test Implementation | [4] |
| Parameter Order | queries then max_workers | [4] |
| Slice Pattern | i:i+100 | [4] |
| Slices | Queries List | [4] |
| Defined With | def keyword | [4] |
| Returns Type | List | [4] |
| Initializes | Results | [4] |
| Measures Time | true | [4] |
| Description | Define a function to handle multiple queries concurrently | [4] |
| List Slicing | queries[i:i+100] | [3] |
| Error Handling | none_detected | [3] |
| Builds Upon | Process Queries | [3] |
| Function Hierarchy | highest_level | [3] |
| Max Concurrent Workers | 10 | [3] |
| Parallelizes Processing | true | [3] |
| Splits Input | into_batches_of_100 | [3] |
| Returns Collection | list | [3] |
| Data Flow | queries_list_to_futures_to_results | [3] |
| Execution Order | submit_batches_then_wait_completion_then_accumulate | [3] |
| Purpose | handle_multiple_queries_concurrently | [3] |
| Future Handling | as_completed | [3] |
| Concurrency Mechanism | ThreadPoolExecutor | [3] |
| Result Accumulation | extend_from_future_result | [3] |
| Iteration Pattern | range_step_100 | [3] |
| Calls Function | Process Queries | [3] |
| Return Type | List | [3] |
| Parameter Default Value | 10 | [3] |
| Slices With Step | 100 | [5] |
| Not Called in Visible Code | true | [5] |
| Concurrent Processing | true | [5] |
| Processing Order | sequential | [5] |
| Return Statement | Return Results | [5] |
| Slice Syntax | i:i+100 | [5] |
| Slice Step | 100 | [5] |
| Loop Iterator | As Completed Futures | [5] |
| Loop Variable | future | [5] |
| Sequential Loop | true | [5] |
| Max Workers Default | 10 | [5] |
| Defines Default | 10 | [5] |
| Calls Method | Future.result | [5] |
| Extends Results | Results | [5] |
| Collects Futures | Futures | [5] |
| Slices Queries | Slicing Operation | [5] |
| Creates Batch | 100 | [5] |
| Has Default Parameter | max_workers=10 | [5] |
| Aggregates | Future Results | [1] |
| Delegates to | Process Batch | [1] |
| Is Method of | Query Rewriter | [1] |
| Async | true | [2] |
| Called in | Example Usage | [2] |
Timeline axis is valid_time — when each source says the fact was true in the world, not when Dontopedia learned about it. Retracted rows are kept for provenance; coloured stripes indicate the context kind.
doc:beam/0eb6f129-cb0b-4c11-b628-1476950b180erewritten_queries.extend(future.result()) return rewritten_queries def _process_batch(self, batch: List[str]) -> List[str]: rewritten_batch = [] for query in batch: rewritten_query =…
doc:beam/fef4fa6f-c278-4da1-b9a8-0acd2941b0c7worker_counts = [5, 10, 20] for batch_size in batch_sizes: for worker_count in worker_counts: start_time = time.time() reformulated_queries = handle_queries(test_queries[:batch_size], max_workers=worker_count) e…
doc:beam/03cde496-4a51-468e-bd28-b870ee2b16a2result = await process_query_existing(query) # Fallback to existing pipeline return result # Modified function to handle queries with fallback async def handle_queries_with_fallback(queries): tasks = [handle_query_with_fal…
Dontopedia is in a read-only public launch. Follow the references and disputed branches now; contributions will open after durable identity and moderation are in place.