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

↓ 483 callersMethodget

(self, relationship_id: str)

src/pipelines/pr_combiner/review_queue.py:112

↓ 423 callersMethodget

Retrieve a cached payload for the given request signature if present and fresh.

src/utils/cache.py:65

↓ 138 callersMethodresolve

Return an absolute trajectory path, creating parent directories as needed.

src/utils/trajectory_paths.py:24

↓ 97 callersMethodinfo

(self, *args, **kwargs)

tests/integration/pipelines/rollout_executor/test_planless_stage_execution.py:170

↓ 95 callersMethodget

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

tests/unit/services/test_sii_agent_client.py:33

↓ 48 callersMethoditems

(self)

src/pipelines/pr_combiner/review_queue.py:115

↓ 39 callersMethodupdate

( self, task_id: str, *, advance: float | int | None = None, completed

src/utils/logger.py:57

↓ 34 callersMethodpublish

Publish a new event for the provided run identifier.

src/services/telemetry_stream.py:163

↓ 30 callersMethodadd

Accumulate another breakdown into the current totals.

src/services/reporting/rollout_dataset_stats.py:24

↓ 26 callersMethodrun

(self, request)

tests/integration/rollout_executor/test_mini_scaffold.py:112

↓ 21 callersMethodfrom_mapping

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

src/utils/config.py:135

↓ 21 callersMethodreset

Clear remembered alerts.

src/services/alerts.py:37

↓ 19 callersMethodevents

Retrieve events for a run, optionally filtered by sequence number.

src/services/telemetry_stream.py:231

↓ 19 callersMethodload

(cls, path: Path)

src/pipelines/pr_combiner/review_queue.py:146

↓ 19 callersFunctionmake_config

(root: Path, workspace: Path)

tests/pipelines/rollout_executor/test_utils.py:36

↓ 18 callersFunction_log_progress

( logger, running: int, queued: int, completed: int, failed: int, *, ui_controller

src/cli/rollout_executor_cli.py:2516

↓ 17 callersFunction_make_stage_spec

(plan_id: str = "plan-001")

tests/unit/cli/test_rollout_executor_cli.py:91

↓ 17 callersMethodincrement

Increment a counter metric.

src/utils/telemetry.py:27

↓ 16 callersFunction_sanitize_component

(value: str)

src/pipelines/rollout_executor/persistence.py:310

↓ 15 callersFunction_make_stage_spec

(stage_id: str)

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

↓ 15 callersFunction_resolve_path

Resolve a possibly relative path from configuration. Relative paths without explicit ``..`` segments are interpreted relative to the project

src/utils/config.py:18

↓ 15 callersMethodrun_stage

( self, *, plan_id: str, stage_id: str, repository: str, query

src/pipelines/rollout_executor/executor.py:465

↓ 15 callersMethodset_baseline

Assign a baseline revision for the requested stage.

src/pipelines/rollout_executor/stage_config.py:49

↓ 14 callersFunction_require_mapping

(value: Any, section: str)

src/utils/config.py:12

↓ 14 callersFunctionload_pr_details

Load PR details from the enhanced dataset, optionally enriching via GitHub API. Args: path: Path to the enhanced dataset JSONL file.

src/pipelines/pr_combiner/input_parser.py:46

↓ 13 callersMethod_run_git

(self, *args: str, strip: bool = True, check: bool = True, input: str | None = None)

src/pipelines/rollout_executor/git_workspace.py:64

↓ 13 callersMethodappend_turn

( self, *, session_id: str, author_role: str, content: str, ex

src/pipelines/rollout_executor/session.py:85

↓ 13 callersMethodrecord

( self, *, plan_id: str, status: str, stage_id: str | None = None,

src/cli/rollout_executor_cli.py:135

↓ 12 callersFunction_make_rollout_config

(tmp_path: Path)

tests/unit/services/test_mini_swe_runner.py:18

↓ 12 callersFunction_validate_commit_sha

Ensure commit SHAs follow expected hexadecimal pattern.

src/models/artifacts.py:29

↓ 12 callersFunctioncreate_sample_history

Create a small repository with two commits and return commit identifiers. Returns: repo_path: Path to the repository root. c

tests/fixtures/rollout_executor/git_workspace.py:45

↓ 12 callersMethodencode

(self, text: str, *, add_special_tokens: bool)

src/pipelines/data_process/pipeline_utils.py:29

↓ 12 callersMethodrun

( self, query: LegacyQueryArtifact, *, session_id: str | None = None,

src/pipelines/rollout_executor/agent.py:50

↓ 11 callersFunction_create_attempt_result

( tmp_path: Path, stage_id: str, attempt: int, *, workspace_path: Path | None = None,

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

↓ 11 callersFunction_evaluation_summary

( tmp_path: Path, stage_id: str, attempt: int, score: float, decision: StageEvaluationDeci

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

↓ 11 callersFunction_run_git

(repo_path: Path, *args: str, input: str | None = None)

tests/fixtures/rollout_executor/git_workspace.py:10

↓ 11 callersMethodbuild

Group PR records into candidate chains.

src/pipelines/pr_combiner/chain_builder.py:48

↓ 11 callersFunctioncleanup_rollout

Clean a single rollout file according to failed stages.

src/services/rollout_cleanup.py:112

↓ 10 callersMethodcreate_session

( self, run_id: str, query_id: str, plan_id: str, repository: str,

src/pipelines/rollout_executor/session.py:46

↓ 10 callersMethodstart

(self, logger: logging.Logger)

src/cli/rollout_executor_ui.py:152

↓ 9 callersFunction_determine_requested_concurrency

(flag_value: int | None)

src/cli/rollout_executor_cli.py:791

↓ 9 callersFunction_record_scaffold_selection

Emit telemetry for scaffold selection so dashboards can track adoption.

src/cli/rollout_executor_cli.py:1796

↓ 9 callersFunction_run_git

(repo: Path, *args: str)

tests/unit/cli/test_mini_scaling_success_dependency_patch_replay.py:17

↓ 9 callersFunction_write_rollout

(path: Path)

tests/unit/services/test_rollout_filter.py:11

↓ 9 callersFunctionload_registry

Load and validate rollouts.json with deterministic duplicate handling.

src/services/rollout_registry.py:126

↓ 9 callersFunctionmake_record

( pr_id: int, repository: str = "repo/example", labels: List[str] | None = None, base_commit:

tests/unit/pipelines/pr_combiner/test_combiner_validation.py:12

↓ 9 callersMethodrun

Execute mini-swe-agent for the provided request.

src/services/mini_swe_runner.py:93

↓ 9 callersMethodrun_session

Execute stages sequentially until completion or failure.

src/pipelines/rollout_executor/stage_session.py:148

↓ 9 callersMethodsnapshot

Produce a snapshot of recorded counters and durations.

src/utils/telemetry.py:47

↓ 8 callersFunction_build_transcript

(stage_id: str, attempt: int)

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

↓ 8 callersFunction_record

(number: int, *, references: list[int] | None = None, created_offset: int = 0)

tests/integration/pipelines/pr_combiner/test_content_chain_builder.py:36

↓ 8 callersFunction_run_stage_sessions

Execute staged sessions sequentially by plan.

src/cli/rollout_executor_cli.py:3156

↓ 8 callersFunction_sanitize

Sanitize identifiers for filesystem compatibility with optional legacy mode.

src/pipelines/query_constructor/persistence.py:189

↓ 8 callersFunction_sanitize_identifier

(identifier: str | None)

src/cli/rollout_executor_cli.py:1989

↓ 8 callersFunctionbuild_config

(tmp_path: Path, *, skip_health_check: bool = False)

tests/unit/services/test_sii_agent_client.py:42

↓ 8 callersFunctionconvert_mini_swe_file

Load a mini-swe-agent trajectory file and emit OpenAI conversation objects.

src/pipelines/data_process/mini_swe_converter.py:186

↓ 8 callersFunctiondiscover_directory_queries

Enumerate query artifacts within a directory, logging skips and limits.

src/cli/rollout_executor_cli.py:2029

↓ 8 callersFunctiondump_model

Persist a Pydantic model as JSON using its dict representation.

src/services/artifact_store.py:62

↓ 8 callersMethodexecute

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

src/pipelines/rollout_executor/stage_session.py:1123

↓ 8 callersMethodjson

(self)

tests/unit/services/test_sii_agent_client.py:23

↓ 8 callersFunctionload_model

Load JSON payload and instantiate the provided model class.

src/services/artifact_store.py:67

↓ 8 callersFunctionmake_transcript

(tmp_path: Path, patch_content: str)

tests/unit/pipelines/evaluator/test_scorer.py:12

↓ 8 callersMethodrun

(self, task: str)

tests/unit/services/test_mini_swe_runner.py:58

↓ 8 callersMethodsync_template

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

src/pipelines/rollout_executor/workspace.py:90

↓ 8 callersMethodvalidate

Return an updated chain with validation status and notes applied.

src/pipelines/pr_combiner/validator.py:33

↓ 7 callersFunction_extract_plan_and_stage

(query: QueryArtifact)

src/cli/rollout_executor_cli.py:2385

↓ 7 callersFunction_full_sha

(prefix: str)

tests/unit/models/test_query_artifact.py:10

↓ 7 callersFunction_run_git

(*args: str, cwd: Path)

src/pipelines/rollout_executor/workspace.py:53

↓ 7 callersFunction_run_git

(*args: str, cwd: Path)

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

↓ 7 callersFunction_stage

(name: str, idx: int, status: StageStatus, ts: str | None)

tests/unit/test_selection.py:8

↓ 7 callersFunction_touch

(path: Path, content: str = "x")

tests/unit/cli/test_scaling_success_skip_materializes_history.py:13

↓ 7 callersFunctionattach_raw_data_relationships

Populate ``timeline_edges`` on PR details using offline raw-data parsing.

src/pipelines/pr_combiner/timeline_strategy.py:24

↓ 7 callersFunctionconfigure_helper

( monkeypatch: pytest.MonkeyPatch, tmp_path: Path, *, config_settings: Dict[str, Any] | None =

tests/unit/utils/test_llm.py:109

↓ 7 callersFunctionemit

(value: Any, source_type: SourceType)

src/pipelines/pr_combiner/reference_parser.py:176

↓ 7 callersFunctionload_pipeline_config

Load the pipeline configuration from a YAML file.

src/utils/config.py:1009

↓ 7 callersFunctionmake_query

(stage_id: str)

tests/pipelines/rollout_executor/test_utils.py:132

↓ 7 callersMethodqueue_run

(self, run: AgentRun)

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

↓ 7 callersMethodrun

Execute the combiner pipeline end-to-end.

src/pipelines/pr_combiner/combiner.py:61

↓ 7 callersMethodrun_session

Invoke rollout agent execution endpoint with provided payload.

src/services/sii_agent_client.py:103

↓ 7 callersMethodsanitize_session_id

(session_id: str)

src/pipelines/rollout_executor/session.py:40

↓ 7 callersFunctionwrite_patch_between

Persist the diff between two commits as a patch file.

tests/fixtures/rollout_executor/git_workspace.py:65

↓ 6 callersMethod_build_model_kwargs

(self, env: Mapping[str, str])

src/services/mini_swe_runner.py:472

↓ 6 callersFunction_commit

(repo: Path, message: str)

tests/unit/services/test_rollout_diff.py:40

↓ 6 callersFunction_load_catalog

Load catalog metadata and map template id to attributes.

src/services/prompt_loader.py:27

↓ 6 callersMethod_lock_path

(self, session_id: str)

src/pipelines/rollout_executor/session.py:287

↓ 6 callersFunction_mirror_mini_trajectory

Copy mini scaffold trajectory into the rollout run directory for parity with sii logs.

src/cli/rollout_executor_cli.py:887

↓ 6 callersFunction_registry_entry

(log_name: str, stages: list[dict[str, object]])

tests/unit/services/test_rollout_filter.py:15

↓ 6 callersFunction_resolve_mini_credentials

Resolve LiteLLM credentials from env overrides or pipeline config.

src/cli/rollout_executor_cli.py:1819

↓ 6 callersFunction_run_git

Run a git command inside the repository and return stdout.

tests/unit/services/test_rollout_diff.py:12

↓ 6 callersFunction_session_directory

(config: RolloutExecutionConfig, session_id: str)

src/pipelines/rollout_executor/persistence.py:314

↓ 6 callersFunction_write_domain_analysis_config

(path: Path)

tests/integration/test_summarize_domain_analysis_classification_llm.py:9

↓ 6 callersFunction_write_file

(repo: Path, relative_path: str, content: str)

tests/unit/services/test_rollout_diff.py:34

↓ 6 callersMethodas_dict

(self)

src/services/reporting/rollout_dataset_stats.py:45

↓ 6 callersFunctioncompute_resume_map

Return mapping plan_id -> (session_id, start_stage_index, workspace_path, agent_session_id).

src/cli/_scaling_success_resume.py:140

↓ 6 callersFunctionconfigure_logging

Configure and return a Rich-backed logger. Args: level: Logging level to apply (e.g., ``logging.INFO``). logger_name: Name of the

src/utils/logger.py:84

↓ 6 callersMethodcreate_workspace

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

src/pipelines/rollout_executor/workspace.py:124

↓ 6 callersFunctiondetails_to_records

Transform PR details into standard PRRecord instances for chaining.

src/pipelines/pr_combiner/input_parser.py:147

↓ 6 callersMethodencode

(self, prompt, add_special_tokens)

tests/unit/cli/test_rollout_stats_cli.py:145

↓ 6 callersFunctionload_rollouts

Load rollouts from JSON with validation and summarize results. Returns (records, stats) where stats contains counts of valid/invalid entries

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

↓ 6 callersFunctionmake_stage_record

Construct a StageRecord aligned to the supplied PR record.

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

next →1–100 of 2,118, ranked by callers