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_compose_content

Merge reasoning and content into a single user-visible payload.

src/pipelines/data_process/mini_swe_converter.py:62

↓ 2 callersFunction_conversation_filename

(session_id: str)

src/pipelines/rollout_executor/persistence.py:322

↓ 2 callersFunction_copy2

(source: Path, dest: Path)

src/pipelines/rollout_executor/persistence.py:621

↓ 2 callersMethod_create_fallback_conversation_log

( self, *, session_id: str, stage_id: str, attempt_index: int,

src/pipelines/rollout_executor/stage_session.py:974

↓ 2 callersFunction_duration_seconds

(run: AgentRun)

src/services/reporting/rollout_summary.py:69

↓ 2 callersFunction_edge_links

(edge: object, repository: str, target_pr: int)

src/pipelines/pr_combiner/chain_builder.py:176

↓ 2 callersMethod_enforce_validation_gate

( self, *, chain_id: str, status: str | None, messages: Sequence[str],

src/pipelines/rollout_executor/executor.py:703

↓ 2 callersFunction_ensure_directory

(path: Path)

src/utils/artifact_store.py:20

↓ 2 callersFunction_ensure_parent

(path: Path)

src/services/artifact_store.py:28

↓ 2 callersFunction_execute_once

(workspace: Path, pipeline_config, enhanced_dataset_path: Path, monkeypatch)

tests/regression/test_pr_combiner_replay.py:21

↓ 2 callersMethod_execute_query

( self, query: QueryArtifact, *, session_id: str | None = None, messag

src/pipelines/rollout_executor/executor.py:324

↓ 2 callersFunction_execute_single_query

( rollout_exec: executor.RolloutExecutor, query: QueryArtifact, dry_run: bool, session_tracker

src/cli/rollout_executor_cli.py:2469

↓ 2 callersFunction_extract_repo_name

(record: Mapping[str, Any])

src/pipelines/pr_combiner/reference_parser.py:87

↓ 2 callersFunction_extract_rollout_timestamp

(value: str)

src/services/reporting/rollout_dataset_stats.py:219

↓ 2 callersFunction_fallback_commit

Generate a deterministic commit SHA fallback for fixtures.

tests/unit/pipelines/query_constructor/testutils.py:18

↓ 2 callersFunction_filter_completed_query_tasks

( tasks: Sequence[QueryTask], resume_state: CompletedRollouts, logger, )

src/cli/rollout_executor_cli.py:2426

↓ 2 callersFunction_filter_completed_stage_specs

( specs: Sequence[staged_queries.StageRunSpec], resume_state: CompletedRollouts, logger, )

src/cli/rollout_executor_cli.py:2401

↓ 2 callersFunction_filter_query_tasks

( tasks: Iterable[QueryTask], template_id: str | None )

src/cli/rollout_executor_cli.py:2087

↓ 2 callersFunction_filter_stage_specs

( specs: Iterable[staged_queries.StageRunSpec], template_id: str | None, )

src/cli/rollout_executor_cli.py:2926

↓ 2 callersMethod_finalize_run

( self, query: QueryArtifact, execution: AgentExecutionResult, *, run_

src/pipelines/rollout_executor/executor.py:378

↓ 2 callersFunction_flush

( writer: pq.ParquetWriter, batch_messages: MutableSequence[list[Dict[str, Any]]], batch_tools: Mu

src/pipelines/data_process/openai_chat_json_to_parquet.py:269

↓ 2 callersFunction_flush_messages

( writer: pq.ParquetWriter, batch: MutableSequence[List[Dict[str, str]]], )

src/pipelines/data_process/instruction_output_json_to_parquet.py:125

↓ 2 callersFunction_format_diff

(generated: str, ground_truth: str)

src/pipelines/evaluator/scorer.py:272

↓ 2 callersFunction_format_timestamp

Return RFC 3339/ISO formatted timestamp for persisted metadata.

src/pipelines/query_constructor/persistence.py:48

↓ 2 callersMethod_get

(self, url: str)

src/services/rollout_diff/generator.py:144

↓ 2 callersMethod_infer_change_type

Infer commit type from PR metadata following Conventional Commits.

src/pipelines/domain_analysis/llm_topic_classifier.py:535

↓ 2 callersFunction_infer_repository_slug

( stage_specs: Sequence[staged_queries.StageRunSpec], queries_path: Path, discovery: DirectoryDisc

src/cli/rollout_executor_cli.py:2107

↓ 2 callersFunction_init_repo

(tmp_path: Path)

tests/unit/services/test_rollout_diff.py:25

↓ 2 callersFunction_install_sii_agent_stub

(monkeypatch: pytest.MonkeyPatch, session_cls)

tests/unit/services/test_sii_agent_client.py:251

↓ 2 callersFunction_invoke

(prompt_text: str)

src/pipelines/evaluator/scorer.py:203

↓ 2 callersMethod_invoke_llm

(self, prompt: str)

src/pipelines/domain_analysis/llm_topic_classifier.py:603

↓ 2 callersMethod_is_enabled

(self)

src/services/mini_swe_runner.py:409

↓ 2 callersFunction_is_mapping_list

(value: Any)

src/utils/parquet_token_counter.py:59

↓ 2 callersFunction_iter_dataset

(path: Path)

src/pipelines/pr_combiner/reference_parser.py:75

↓ 2 callersMethod_json

(response: Response)

src/services/rollout_diff/generator.py:163

↓ 2 callersFunction_json_stringify

(value: Any)

src/pipelines/data_process/openai_chat_json_to_parquet.py:159

↓ 2 callersMethod_list_logs

(directory: Path)

src/services/sii_agent_client.py:229

↓ 2 callersFunction_load_composite_config

(tmp_path: Path)

tests/integration/pipelines/pr_combiner/test_timeline_strategy.py:13

↓ 2 callersFunction_load_registry

Load registry records, tolerating absent files and cleaning stray temps.

src/pipelines/rollout_executor/persistence.py:1208

↓ 2 callersFunction_load_successful_plan_ids

(registry_path: Path, logger)

src/cli/rollout_executor_cli.py:2254

↓ 2 callersFunction_locked_registry

Ensure registry directory exists, recover temps, and lock for exclusive writes.

src/pipelines/rollout_executor/persistence.py:1183

↓ 2 callersFunction_log_discovery_entries

(logger, entries: list[Path], message: str)

src/cli/rollout_executor_cli.py:2021

↓ 2 callersFunction_make

(chain_suffix: str, generated_at: datetime, annotation_id: str)

tests/integration/pipelines/query_constructor/test_persistence_repo_scoped.py:42

↓ 2 callersFunction_make_config

(tmp_path: Path)

tests/integration/rollout_executor/test_sdk_handoff.py:38

↓ 2 callersFunction_make_config

(tmp_path: Path, allow_bypass: bool = False)

tests/integration/rollout_executor/test_validation_gate.py:25

↓ 2 callersFunction_make_execution

(stage_id: str, patch_file: Path)

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

↓ 2 callersFunction_make_legacy_query

(status: str)

tests/integration/rollout_executor/test_validation_gate.py:82

↓ 2 callersFunction_make_query

()

tests/unit/pipelines/rollout_executor/test_agent.py:47

↓ 2 callersFunction_make_query

( *, plan_id: str, stage_id: str, repository: str, baseline: str, dependencies: list[s

tests/regression/pipelines/rollout_executor/test_stage_preservation.py:97

↓ 2 callersFunction_make_rollout_config

(tmp_path: Path)

tests/unit/services/test_mini_swe_runner_timeout.py:19

↓ 2 callersFunction_make_spec

(*, query: object, ground_truth_patch: str | None)

tests/unit/pipelines/rollout_executor/test_stage_evaluator_ground_truth.py:12

↓ 2 callersFunction_make_template

()

tests/integration/rollout_executor/test_sdk_handoff.py:79

↓ 2 callersFunction_make_template

()

tests/integration/rollout_executor/test_validation_gate.py:68

↓ 2 callersFunction_make_template

()

tests/unit/pipelines/rollout_executor/test_agent.py:34

↓ 2 callersFunction_maybe_extract

(payload: Any, *, key: str)

src/pipelines/rollout_executor/staged_queries.py:299

↓ 2 callersFunction_merge_patch_text

(patches: Iterable[DiffPatch | Mapping[str, Any]])

src/pipelines/query_constructor/serialization.py:63

↓ 2 callersFunction_mirror_attempt_trajectory

Copy per-attempt trajectories into a dedicated attempts directory under the run dir.

src/cli/rollout_executor_cli.py:902

↓ 2 callersFunction_normalise_diff_path

(raw_path: str)

src/services/rollout_diff/generator.py:330

↓ 2 callersFunction_normalize_content

(content: Any)

src/pipelines/data_process/mini_swe_converter.py:34

↓ 2 callersFunction_normalize_scaffold_mode

Normalize scaffold identifiers to stable `sii`/`mini` values. The codebase historically referred to scaffolds both by short CLI flags (``sii`

src/cli/_scaling_success_resume.py:33

↓ 2 callersFunction_normalize_sequence

(value: Any)

src/pipelines/rollout_executor/staged_queries.py:305

↓ 2 callersMethod_normalize_type

(self, candidate: str)

src/pipelines/domain_analysis/commit_intent.py:55

↓ 2 callersFunction_parse_counts

(raw: object, *, label: str, source: Path)

src/utils/domain_analysis_rollup.py:101

↓ 2 callersFunction_parse_datetime

(value: Optional[str])

src/pipelines/pr_combiner/models.py:12

↓ 2 callersFunction_parse_datetime

(value: Any)

src/pipelines/pr_combiner/reference_parser.py:246

↓ 2 callersMethod_parse_llm_json

(self, content: str, *, context: str)

src/pipelines/domain_analysis/llm_topic_classifier.py:674

↓ 2 callersFunction_parse_pr_number

(candidate: Any)

src/pipelines/pr_combiner/reference_parser.py:235

↓ 2 callersFunction_parse_stage_number

(stage_id: str)

src/cli/rollout_filter_cli.py:58

↓ 2 callersFunction_parse_stage_number

(stage_id: str)

src/services/reporting/rollout_filter.py:23

↓ 2 callersFunction_partition_stage_files

( file_paths: Sequence[Path], )

src/cli/rollout_executor_cli.py:3354

↓ 2 callersFunction_percentile

(values: Sequence[float], percentile: float)

src/services/reporting/rollout_summary.py:19

↓ 2 callersFunction_persist_conversation_payload

( directory: Path, session_id: str, payload: dict[str, Any] )

src/pipelines/rollout_executor/persistence.py:333

↓ 2 callersFunction_prepare_resume_state

( *, run_dir: Path, manifest_path: Path, global_registry: Path, logger, enable_resume:

src/cli/rollout_executor_cli.py:2356

↓ 2 callersFunction_processing_result

(base_stem: str)

tests/contract/test_relationship_export_api.py:41

↓ 2 callersFunction_record

(number: int)

tests/integration/pipelines/pr_combiner/test_export_artifact.py:20

↓ 2 callersFunction_record

(number: int)

tests/contract/test_relationship_export_api.py:19

↓ 2 callersFunction_record_run_completion

( manifest: RunManifest | None, query: QueryArtifact, run: AgentRun )

src/cli/rollout_executor_cli.py:2455

↓ 2 callersFunction_recover_temp_file

Handle leftover temp writes to avoid partial/corrupted content.

src/pipelines/rollout_executor/persistence.py:1224

↓ 2 callersFunction_redact_path

(path: Optional[str])

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

↓ 2 callersFunction_relativize_path

(path: Path | str)

src/cli/rollout_executor_cli.py:4034

↓ 2 callersMethod_render_layout

(self)

src/cli/rollout_executor_ui.py:304

↓ 2 callersFunction_render_prompt

(gt: str, patch: str)

src/pipelines/evaluator/scorer.py:183

↓ 2 callersFunction_resolve_commit_sha

Return commit SHA, falling back when provided.

src/pipelines/query_constructor/stage_orchestrator.py:30

↓ 2 callersFunction_resolve_created_at

Normalize generated_at payloads to datetime instances.

src/pipelines/rollout_executor/staged_queries.py:80

↓ 2 callersFunction_resolve_github_base

(record: PRRecordSummary, previous_head: Optional[str], *, client: GitHubCompareClient)

src/services/rollout_diff/generator.py:202

↓ 2 callersFunction_resolve_ground_truth_patch

( stage_value: str | None, raw_stage: Mapping[str, Any] | Any, patch_payload: Iterable[dict | Diff

src/pipelines/rollout_executor/staged_queries.py:232

↓ 2 callersFunction_resolve_local_base

(record: PRRecordSummary, previous_head: Optional[str], *, git: _GitRunner)

src/services/rollout_diff/generator.py:276

↓ 2 callersFunction_resolve_mini_trajectory_path

( plan_id: str, *, base: Path = MINI_TRAJECTORY_ROOT, now: datetime | None = None, )

src/cli/rollout_executor_cli.py:875

↓ 2 callersMethod_resolve_patch_path

(self, path_value: str | None)

src/pipelines/rollout_executor/stage_session.py:1354

↓ 2 callersMethod_resolve_sdk_auth_type

(value: str | None)

src/services/sii_agent_client.py:241

↓ 2 callersMethod_resolve_task

(self, request: MiniSweRunRequest)

src/services/mini_swe_runner.py:413

↓ 2 callersFunction_revision_attempt_dir

( plan_id: str, stage_id: str, execution_id: str, config: RolloutExecutionConfig )

src/pipelines/rollout_executor/persistence.py:975

↓ 2 callersFunction_run_record

(stage_id: str)

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

↓ 2 callersFunction_sanitize_component

(value: str)

src/cli/rollout_executor_cli.py:2099

↓ 2 callersMethod_sanitize_component

(value: str)

src/pipelines/rollout_executor/stage_session.py:1090

↓ 2 callersFunction_sanitize_identifier

(identifier: str)

src/utils/artifact_store.py:14

↓ 2 callersFunction_select_mini_concurrency

Mini scaffold concurrency: ignore directory-mode fallback and clamp to task count.

src/cli/rollout_executor_cli.py:849

↓ 2 callersFunction_slugify

(repository: str)

src/pipelines/rollout_executor/workspace.py:42

↓ 2 callersFunction_stage_statuses

(entry: RegistryEntry)

src/cli/rollout_filter_cli.py:67

↓ 2 callersFunction_stage_statuses

Return a mapping of stage number -> status for a registry entry.

src/services/reporting/rollout_filter.py:32

← previous next →301–400 of 2,118, ranked by callers