Functions — github.com/GAIR-NLP/daVinci-Agency

hub / github.com/GAIR-NLP/daVinci-Agency / functions

Functions2,118 in github.com/GAIR-NLP/daVinci-Agency

⨍ Functions 2,118◇ Types & classes 341↳ Endpoints 14

↓ 2 callersFunction_summarize_interactions

Compute average message rounds for an OpenAI-style conversation list.

src/services/reporting/rollout_dataset_stats.py:318

↓ 2 callersMethod_update_ledger

( self, plan_id: str, stage_id: str, patch_path: str | None )

src/pipelines/rollout_executor/stage_session.py:664

↓ 2 callersMethod_url

(self, path: str)

src/pipelines/pr_combiner/github_client.py:34

↓ 2 callersFunction_validate_concurrency_bounds

(value: int, *, source: str)

src/cli/rollout_executor_cli.py:776

↓ 2 callersFunction_validate_full_commit_sha

Ensure commit SHAs are fully qualified 40-character values.

src/models/artifacts.py:37

↓ 2 callersMethod_validate_trajectory

(self, path: Path)

src/services/mini_swe_runner.py:500

↓ 2 callersFunction_walk

(node: object)

src/pipelines/pr_combiner/input_parser.py:239

↓ 2 callersFunction_write_checksum

(path: Path, payload: bytes)

src/pipelines/rollout_executor/persistence.py:326

↓ 2 callersFunction_write_jsonl

(path: Path, records: list[dict])

tests/unit/data_processing/test_enhanced_repo_rollup.py:13

↓ 2 callersFunction_write_queries

(tmp_path: Path)

tests/integration/rollout_executor/test_mini_scaffold.py:54

↓ 2 callersFunction_write_registry

(path: Path, records: list[dict])

tests/unit/cli/test_scaling_success_resume_scaffold_isolation.py:12

↓ 2 callersFunction_write_summary

( path: Path, *, topic_counts: dict[str, int], feature_counts: dict[str, int], )

tests/integration/test_rollup_domain_analysis_summary.py:9

↓ 2 callersFunction_write_summary

( path: Path, *, topic_counts: dict[str, int], feature_counts: dict[str, int], )

tests/acceptance/scripts/test_rollup_domain_analysis_summary.py:9

↓ 2 callersMethodapply_chat_template

( self, messages: List[Dict[str, Any]], *, tools: List[Dict[str, Any]],

src/pipelines/data_process/pipeline_utils.py:20

↓ 2 callersMethodapply_chat_template

(self, messages, tokenize, add_generation_prompt)

tests/unit/cli/test_rollout_stats_cli.py:142

↓ 2 callersMethodas_bullets

Render the taxonomy as bullet points for prompting.

src/pipelines/domain_analysis/llm_topic_classifier.py:78

↓ 2 callersMethodattempt_path

Return per-attempt raw trajectory path to avoid overwriting prior runs.

src/cli/rollout_executor_cli.py:234

↓ 2 callersFunctionbuild_archive_path

Build destination archive path.

src/pipelines/rollout_executor/scaling_success/archive.py:27

↓ 2 callersMethodcapture_delta

Return the current workspace diff relative to the provided base revision (defaults to HEAD).

src/pipelines/rollout_executor/git_workspace.py:253

↓ 2 callersFunctioncommit_result

(result: _ChainGenerationResult)

src/cli/query_constructor_cli.py:191

↓ 2 callersMethodcompare

(self, base: str, head: str)

src/services/rollout_diff/generator.py:130

↓ 2 callersFunctioncompute_success_stats

(rollout: RolloutRecord)

src/pipelines/rollout_executor/scaling_success/selection_helpers.py:22

↓ 2 callersFunctionconvert_events_to_conversation

(events: List[Dict[str, Any]])

src/pipelines/data_process/convert_to_openai.py:131

↓ 2 callersFunctionconvert_instruction_output_json_to_parquet

Convert ``instruction``/``output`` JSON array to messages Parquet. Args: input_path: Path to a JSON file containing a top-level array of

src/pipelines/data_process/instruction_output_json_to_parquet.py:139

↓ 2 callersFunctionconvert_tool_definitions

(raw_tools: Optional[List[Dict[str, Any]]])

src/pipelines/data_process/convert_to_openai.py:66

↓ 2 callersFunctioncount_parquet_tokens

Count total tokens in a Parquet file using a HuggingFace tokenizer. Args: parquet_path: Path to the parquet file. tokenizer_path:

src/utils/parquet_token_counter.py:130

↓ 2 callersFunctioncreate_progress

Context manager yielding a tqdm-backed progress reporter.

src/utils/logger.py:120

↓ 2 callersMethodexecute

( self, spec: StageRunSpec, *, plan_id: str, attempt_index: int,

tests/unit/pipelines/rollout_executor/test_stage_session.py:112

↓ 2 callersMethodexport_transcript

( self, session_id: str, *, json_path: Path | None = None, csv_path: P

src/pipelines/rollout_executor/session.py:256

↓ 2 callersFunctionextract_references

Return a mapping of referenced PR numbers to evidence snippets. Args: texts: Iterable of content strings to scan. context: Maximu

src/pipelines/pr_combiner/content_reference_parser.py:25

↓ 2 callersFunctionformat_outputs

Return dict with both human-readable and structured outputs.

src/pipelines/rollout_executor/scaling_success/output.py:49

↓ 2 callersMethodfrom_dict

(cls, data: dict, registry_path: Path)

src/services/rollout_registry.py:83

↓ 2 callersMethodfrom_dict

(cls, data: dict[str, Any])

src/pipelines/rollout_executor/scaling_success/models.py:56

↓ 2 callersMethodget_plan

Return the rollout plan for the provided identifier.

src/pipelines/rollout_executor/stage_config.py:44

↓ 2 callersMethodget_profile

(self, auth_type=None)

tests/integration/pipelines/rollout_executor/test_stage_session_cli.py:213

↓ 2 callersMethodget_relationships

( self, run_id: str, *, strategy: str | None = None, include_provenanc

src/services/api/relationship_combiner.py:34

↓ 2 callersMethodget_rollout

Return rollout record and latest promotion status.

src/services/api/rollouts.py:42

↓ 2 callersMethodis_failed

(self)

src/services/rollout_registry.py:23

↓ 2 callersFunctioniter_input_files

(input_path: Path)

src/pipelines/data_process/convert_to_openai.py:337

↓ 2 callersMethodlist_stages

List stage baseline assignments for the plan.

src/services/api/rollouts.py:65

↓ 2 callersMethodload_chains

Load PR chain objects from the configured JSONL artifacts.

src/pipelines/domain_analysis/data_loader.py:89

↓ 2 callersFunctionload_domain_analysis_counts

Load a single domain analysis summary file and return its counts.

src/utils/domain_analysis_rollup.py:48

↓ 2 callersFunctionload_repository_records

Load repository records from a JSON file. Args: input_path: Path to a JSON document containing an array of repository statist

src/data_processing/star_dataset.py:21

↓ 2 callersFunctionload_runs

Load run records within the configured window.

src/services/reporting/rollout_summary.py:137

↓ 2 callersFunctionload_statuses

Load environment status files if available.

src/services/reporting/rollout_summary.py:148

↓ 2 callersFunctionmake_config

(tmp_path: Path, *, conversation_logs_dir: Path | None = None)

tests/unit/pipelines/rollout_executor/test_executor.py:76

↓ 2 callersFunctionmake_query

(template_id: str)

tests/integration/test_rollout_executor_matrix.py:67

↓ 2 callersFunctionmake_query

()

tests/unit/pipelines/rollout_executor/test_executor.py:59

↓ 2 callersFunctionmake_run

(run_id: str, template_id: str, status: str, duration_seconds: float)

tests/integration/test_rollout_reporting_job.py:33

↓ 2 callersFunctionmake_status

(template_id: str, verdict: str, eligible: bool)

tests/integration/test_rollout_reporting_job.py:52

↓ 2 callersFunctionmake_status

(template_id: str, verdict: str, eligible: bool)

tests/unit/services/test_rollout_reporting.py:31

↓ 2 callersFunctionmake_template

(template_id: str)

tests/integration/test_rollout_executor_matrix.py:54

↓ 2 callersFunctionmake_template

()

tests/unit/pipelines/rollout_executor/test_executor.py:46

↓ 2 callersMethodmark_error

(self, message: str)

src/services/rollout_cleanup.py:39

↓ 2 callersMethodmaybe_store

Persist progress when the configured interval has been reached.

src/pipelines/pr_combiner/checkpoint.py:46

↓ 2 callersMethodobserve_duration

Record a duration value (in seconds) for the provided metric.

src/utils/telemetry.py:32

↓ 2 callersFunctionpersist_stage_patch_ledger

Persist the provided ledger model.

src/pipelines/rollout_executor/persistence.py:225

↓ 2 callersMethodpost

(self, url: str, *, json: Dict[str, object], headers: Dict[str, str], timeout: float)

tests/unit/services/test_sii_agent_client.py:37

↓ 2 callersFunctionprepare_annotations

Ensure every chain has an associated annotation, creating supplements when needed.

src/pipelines/query_constructor/builder.py:125

↓ 2 callersFunctionprune_to_assistant_without_tools

(messages: List[Any])

src/pipelines/data_process/ensure_assistant_tail.py:43

↓ 2 callersMethodpublish_stage_session

Publish a staged-session lifecycle telemetry event.

src/services/telemetry_stream.py:188

↓ 2 callersFunctionresolve_repository_directory

Return the filesystem directory for a repository scoped query bundle. Args: repository: Repository slug in ``owner/repo`` format.

src/pipelines/query_constructor/persistence.py:259

↓ 2 callersMethodrun

(self, *args: str, strip: bool = True)

src/services/rollout_diff/generator.py:235

↓ 2 callersFunctionsanitize_message

Strip ANSI sequences and bounding whitespace.

src/cli/rollout_executor_ui.py:351

↓ 2 callersMethodseed_plan_trajectory

Seed the next aggregated trajectory with messages from a prior run. scaling-success may resume a plan at a later stage. In those cases we wan

src/cli/rollout_executor_cli.py:348

↓ 2 callersFunctionsort_repository_records

Sort repository records by pull request count. Args: records: Iterable of repository records to sort. descending: Whether to sort

src/data_processing/star_dataset.py:56

↓ 2 callersMethodstage_completed

(self, plan_id: str, stage_id: str)

src/pipelines/rollout_executor/stage_session.py:1284

↓ 2 callersMethodstream_events

Return telemetry events for the run.

src/services/api/rollouts.py:52

↓ 2 callersFunctionstream_raw_relationships

Yield raw-data relationships discovered within the dataset.

src/pipelines/pr_combiner/reference_parser.py:44

↓ 2 callersFunctionstringify_conversation

Return a rewritten conversation and counts of rewrites. Returns: (rewritten_conversation, rewritten_messages, rewritten_tool_calls)

src/pipelines/data_process/openai_json_stringify.py:115

↓ 2 callersMethodsync_template

(self, repository: str, *, revision: str)

tests/integration/pipelines/rollout_executor/test_stage_session_cli.py:63

↓ 2 callersMethodto_dict

(self)

src/pipelines/pr_combiner/review_queue.py:52

↓ 2 callersMethodto_dict

(self)

src/pipelines/query_constructor/reporting.py:27

↓ 2 callersMethodto_dict

(self)

tests/unit/cli/test_domain_analysis_cli_parallel.py:10

↓ 2 callersMethodto_stats

Convert the accumulator into a JSON-serializable payload.

src/data_processing/enhanced_repo_rollup.py:31

↓ 2 callersFunctionwrite_summary_files

Generate summary artifacts (JSON + CSV) for reporting.

src/services/reporting/rollout_summary.py:160

↓ 1 callersMethod__init__

(self, repo_path: str | Path, *, handle: WorkspaceHandle | None = None)

src/pipelines/rollout_executor/git_workspace.py:54

↓ 1 callersMethod_agent_factory

(**_: Any)

tests/unit/services/test_mini_swe_runner.py:247

↓ 1 callersFunction_aggregate_repo_stats

(input_dir: Path)

src/data_processing/enhanced_repo_rollup.py:69

↓ 1 callersFunction_analyze_parallel

Analyze chains in parallel using a thread pool.

src/cli/domain_analysis_cli.py:124

↓ 1 callersMethod_analyze_pr

( self, *, chain: PRChain, pr_record: PRRecord, raw_record: Optional[A

src/pipelines/domain_analysis/llm_topic_classifier.py:346

↓ 1 callersFunction_artifact_path

( plan_id: str, artifact_id: str, config: RolloutExecutionConfig )

src/pipelines/rollout_executor/persistence.py:1057

↓ 1 callersFunction_assert_executor_signature

()

tests/integration/test_rollout_executor_real_client.py:13

↓ 1 callersFunction_assert_executor_signature

()

tests/regression/rollout/test_promotion_gating.py:46

↓ 1 callersMethod_augment_conversation_log

( self, path: Path, messages: Sequence[dict[str, str]] )

src/pipelines/rollout_executor/stage_session.py:940

↓ 1 callersFunction_best_session_for_plan

( plan_id: str, plan_specs: Sequence[staged_queries.StageRunSpec], records: Iterable[dict], *,

src/cli/_scaling_success_resume.py:74

↓ 1 callersFunction_build_annotation_payload

(annotation: HumanEffortAnnotation)

src/pipelines/query_constructor/prompt_binding.py:79

↓ 1 callersFunction_build_chain_payload

(chain: PRChain)

src/pipelines/query_constructor/prompt_binding.py:67

↓ 1 callersMethod_build_chain_prompt

( self, chain: PRChain, pr_insights: Sequence[PRTopicInsight] )

src/pipelines/domain_analysis/llm_topic_classifier.py:474

↓ 1 callersMethod_build_commit_links

(self, chains: List[PRChain])

src/pipelines/pr_combiner/combiner.py:251

↓ 1 callersFunction_build_completed_rollouts

( *, manifest_entries: Sequence[Mapping[str, Any]], derived_entries: Sequence[Mapping[str, Any]],

src/cli/rollout_executor_cli.py:2324

↓ 1 callersFunction_build_environment_spec

(chain: PRChain)

src/pipelines/query_constructor/builder.py:298

↓ 1 callersMethod_build_environment_status

( self, run: AgentRun, execution: AgentExecutionResult )

src/pipelines/rollout_executor/executor.py:797

↓ 1 callersFunction_build_export_artifact

(base_stem: str, result: ProcessingResult)

src/pipelines/pr_combiner/output_writer.py:47

↓ 1 callersMethod_build_ground_truth

( self, *, session_id: str, spec: StageRunSpec, attempt_index: int,

src/pipelines/rollout_executor/stage_session.py:632

↓ 1 callersMethod_build_initial_messages

(self, spec: StageRunSpec)

src/pipelines/rollout_executor/stage_session.py:1519

↓ 1 callersMethod_build_metadata

( self, chains: List[PRChain], *, total_records: int, snapshot: Teleme

src/pipelines/pr_combiner/combiner.py:277

↓ 1 callersFunction_build_patch_summary

(chain: PRChain)

src/pipelines/query_constructor/prompt_binding.py:156

↓ 1 callersMethod_build_pr_prompt

( self, chain: PRChain, pr_record: PRRecord, raw_record: Optional[Any],

src/pipelines/domain_analysis/llm_topic_classifier.py:385

↓ 1 callersMethod_build_progress_bar

(percent: float, width: int = 24)

src/cli/rollout_executor_ui.py:344

← previous next →401–500 of 2,118, ranked by callers