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

↓ 6 callersMethodraise_for_status

(self)

tests/unit/services/test_sii_agent_client.py:19

↓ 6 callersFunctionreset_repository_token_registry

Reset collision tracking registry (primarily for tests).

src/pipelines/query_constructor/persistence.py:253

↓ 6 callersMethodrun

(self, query: QueryArtifact, *, persist_state: bool = True)

src/pipelines/rollout_executor/executor.py:302

↓ 6 callersMethodsubmit

(self, fn, /, *args, **kwargs)

tests/unit/scripts/test_rollout_llm_evaluator.py:20

↓ 6 callersMethodswitch_revision

Checkout a revision and reapply provided patches.

src/pipelines/rollout_executor/git_workspace.py:194

↓ 6 callersFunctionwrite_config

(tmp_path: Path, content: str)

tests/unit/utils/test_config.py:8

↓ 5 callersFunction_execute_stage_plan

( plan_specs: Sequence[staged_queries.StageRunSpec], *, orchestrator: StageRolloutOrchestrator,

src/cli/rollout_executor_cli.py:2980

↓ 5 callersFunction_head

(path: Path)

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

↓ 5 callersMethod_load_session

(self, session_id: str)

src/pipelines/rollout_executor/session.py:244

↓ 5 callersFunction_make_rollout_config

(tmp_path: Path)

tests/unit/cli/test_rollout_executor_cli.py:132

↓ 5 callersFunction_make_run

(attempt_index: int, session_id: str | None)

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

↓ 5 callersFunction_publish_queue_metrics

( running: int, queued: int, completed: int, failed: int )

src/cli/rollout_executor_cli.py:2547

↓ 5 callersFunction_run_cli_with_staged_payload

( monkeypatch: pytest.MonkeyPatch, tmp_path: Path, *, use_flag: bool, as_directory: bool =

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

↓ 5 callersFunction_run_stage_sessions_concurrently

Execute staged sessions across plans using worker threads.

src/cli/rollout_executor_cli.py:3238

↓ 5 callersFunction_running_snapshot

(queued: int)

src/cli/rollout_executor_cli.py:1020

↓ 5 callersFunction_safe_print

(message: str)

src/cli/rollout_filter_cli.py:119

↓ 5 callersFunction_touch

(path: Path, age_seconds: int = 0)

tests/unit/test_retention.py:8

↓ 5 callersFunction_truncate_text

(value: str, *, limit: int)

src/pipelines/query_constructor/prompt_binding.py:18

↓ 5 callersFunction_write_registry

(path: Path, entries: list[dict[str, object]])

tests/unit/services/test_rollout_dataset_stats.py:21

↓ 5 callersFunction_write_rollout

(path: Path, tokens: tuple[int, int, int], include_statistics: bool = True)

tests/unit/services/test_rollout_dataset_stats.py:13

↓ 5 callersMethodas_payload

Return JSON-friendly payload.

src/services/telemetry_stream.py:55

↓ 5 callersFunctionbuild_patch_pairs

Load patches from disk and return (label, content) tuples.

src/pipelines/rollout_executor/git_workspace.py:397

↓ 5 callersFunctionbuild_worklist

Cross-reference registry entries against filesystem to prepare actionable work.

src/services/rollout_registry.py:150

↓ 5 callersFunctioncommit_file

Write a file and commit it.

tests/fixtures/rollout_executor/git_workspace.py:34

↓ 5 callersMethodencode

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

src/utils/parquet_token_counter.py:35

↓ 5 callersMethodenqueue

( self, *, relationship_id: str, source_pr: str, target_pr: str,

src/pipelines/pr_combiner/review_queue.py:90

↓ 5 callersFunctionfilter_rollouts_by_stage

Filter rollout JSON files by stage success and optionally copy them.

src/services/reporting/rollout_filter.py:60

↓ 5 callersMethodpending_items

(self)

src/pipelines/pr_combiner/review_queue.py:109

↓ 5 callersFunctionplan_continuation

Generate continuation plan based on selection result.

src/pipelines/rollout_executor/scaling_success/planner.py:42

↓ 5 callersMethodput_stage_baseline

Assign or update a stage baseline.

src/services/api/rollouts.py:70

↓ 5 callersMethodrecord_attempt

( self, *, stage_id: str, attempt_index: int, status: str, dur

src/cli/rollout_executor_cli.py:278

↓ 5 callersMethodresume_session

(self, session_id: str)

src/pipelines/rollout_executor/session.py:147

↓ 5 callersMethodrun

(self, task: str, **kwargs: Any)

src/services/mini_swe_runner.py:61

↓ 5 callersMethodrun_all

( self, queries: Iterable[QueryArtifact], *, persist_state: bool = True )

src/pipelines/rollout_executor/executor.py:457

↓ 5 callersFunctionsanitize_repository_token

Return canonical sanitized token for repository-scoped storage. Args: raw_slug: Repository slug in ``owner/repo`` form. Returns:

src/pipelines/query_constructor/persistence.py:197

↓ 5 callersFunctionselect_best_rollout

Pick rollout with max success count, breaking ties by last success time.

src/pipelines/rollout_executor/scaling_success/selector.py:32

↓ 5 callersMethodset_total_tasks

(self, total: int)

src/cli/rollout_executor_ui.py:204

↓ 5 callersFunctionsummarize_rollout_dataset

Aggregate tokens and success metrics for rollout artifacts.

src/services/reporting/rollout_dataset_stats.py:456

↓ 5 callersMethodto_dict

(self)

src/services/rollout_summary.py:27

↓ 5 callersFunctionwrite_outputs

Write chains, metadata, and failure reports to disk.

src/pipelines/pr_combiner/output_writer.py:13

↓ 4 callersMethod_delete_workspace_state

(self, plan_id: str)

src/pipelines/rollout_executor/stage_session.py:1476

↓ 4 callersFunction_ensure_bash_in_tools

(tools: Sequence[Mapping[str, Any]] | None)

src/pipelines/data_process/parquet_tools.py:40

↓ 4 callersFunction_head

(path: Path)

tests/integration/pipelines/rollout_executor/test_workspace_copy.py:42

↓ 4 callersFunction_load_contract

()

tests/contract/rollout_executor/test_sessions_contract.py:10

↓ 4 callersFunction_make_query_artifact

( repository: str, *, generated_at: datetime, annotation_id: str, start_pr_id: str, ch

tests/unit/pipelines/query_constructor/test_persistence.py:51

↓ 4 callersFunction_make_query_task

(plan_id: str, *, source: str = "query.json")

tests/unit/cli/test_rollout_executor_cli.py:118

↓ 4 callersFunction_placeholder_telemetry

(request: PRChainDiffRequest)

src/services/rollout_diff/generator.py:115

↓ 4 callersFunction_read_json_lines

(path: Path)

src/pipelines/query_constructor/persistence.py:75

↓ 4 callersFunction_registry_key

Derive a stable key for deduplication.

src/pipelines/rollout_executor/persistence.py:1197

↓ 4 callersMethod_resolve_path

(self, repository: str, plan_id: str | None)

src/cli/rollout_executor_cli.py:1932

↓ 4 callersFunction_run_git

(*args: str, cwd: Path)

tests/integration/pipelines/rollout_executor/test_workspace_copy.py:12

↓ 4 callersFunction_run_git

(*args: str, cwd: Path)

tests/unit/services/test_telemetry_stream.py:28

↓ 4 callersFunction_run_git

(*args: str, cwd: Path)

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

↓ 4 callersFunction_run_git

(*args: str, cwd: Path)

tests/acceptance/pipelines/rollout_executor/test_staged_rollout.py:69

↓ 4 callersFunction_run_mini_scaffold

( *, args: argparse.Namespace, pipeline_config, credentials: Mapping[str, str], logger,

src/cli/rollout_executor_cli.py:1439

↓ 4 callersFunction_run_mini_with_timeout

Run mini agent with a hard timeout so we can fail fast and continue.

src/cli/rollout_executor_cli.py:917

↓ 4 callersFunction_sleep

(backoff: float)

src/utils/llm.py:96

↓ 4 callersFunction_sort_patches

(patches: Iterable[DiffPatch])

src/services/rollout_diff/generator.py:339

↓ 4 callersFunction_truncate

(value: str, *, limit: int, label: str)

src/pipelines/evaluator/scorer.py:173

↓ 4 callersFunction_workspace_token_for_plan

(plan_id: str)

src/cli/rollout_executor_cli.py:178

↓ 4 callersFunction_write_registry

(path: Path, filename: str, status: str)

tests/unit/cli/test_rollout_stats_cli.py:27

↓ 4 callersMethodacquire

(self, key: str | None)

src/cli/rollout_executor_cli.py:207

↓ 4 callersMethodadd_task

(self, description: str, total: int | None = None, *, unit: str | None = None)

src/utils/logger.py:45

↓ 4 callersMethodas_dict

(self)

src/services/reporting/rollout_summary.py:63

↓ 4 callersFunctionbuild_parser

()

src/cli/rollout_executor_cli.py:2774

↓ 4 callersFunctionbuild_session_metrics

Aggregate session telemetry metrics from recorded turns.

src/pipelines/rollout_executor/telemetry.py:32

↓ 4 callersFunctionbuild_summary

( outcomes: Iterable[CleanupOutcome], *, source_root: Path, derived_root: Path, elapsed_se

src/services/rollout_summary.py:40

↓ 4 callersMethodcheckout

Checkout the requested revision, returning the resulting HEAD SHA.

src/pipelines/rollout_executor/git_workspace.py:111

↓ 4 callersFunctionconvert_file

(path: Path)

src/pipelines/data_process/convert_to_openai.py:254

↓ 4 callersMethodcurrent_revision

Return the current HEAD commit SHA.

src/pipelines/rollout_executor/git_workspace.py:107

↓ 4 callersFunctionensure_arguments_string

(arguments: Any)

src/pipelines/data_process/convert_to_openai.py:111

↓ 4 callersMethodfrom_mapping

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

src/pipelines/domain_analysis/llm_topic_classifier.py:133

↓ 4 callersFunctionget_logger

Retrieve a configured logger, defaulting to the shared pipeline logger.

src/utils/logger.py:112

↓ 4 callersMethodhandshake

Verify connectivity with user and rollout agents.

src/services/sii_agent_client.py:79

↓ 4 callersMethodload

Return PR chains paired with repository metadata when available.

src/pipelines/domain_analysis/data_loader.py:110

↓ 4 callersFunctionload_registry_statuses

Load rollout registry entries and index them for fast lookup.

src/services/reporting/rollout_dataset_stats.py:275

↓ 4 callersFunctionmake_annotation

(constraints: list[str] | None = None)

tests/unit/pipelines/query_constructor/test_query_templates.py:41

↓ 4 callersFunctionmake_config

(root: Path)

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

↓ 4 callersMethodnormalize

Resolve a string to the closest taxonomy entry.

src/pipelines/domain_analysis/llm_topic_classifier.py:62

↓ 4 callersMethodparse

Infer the commit intent from a PR title.

src/pipelines/domain_analysis/commit_intent.py:39

↓ 4 callersFunctionpersist_conversation_registry_entry

Append conversation session metadata to the rollout registry.

src/pipelines/rollout_executor/persistence.py:723

↓ 4 callersFunctionprepare_stage_environment

(tmp_path: Path)

tests/pipelines/rollout_executor/test_utils.py:75

↓ 4 callersFunctionprune_archives

Prune archived workspaces under base using count and optional age policies. - keep_last: keep newest N archives per query. - max_age_day

src/pipelines/rollout_executor/scaling_success/retention.py:21

↓ 4 callersFunctionresolve_paths

Validate and normalize source/derived paths.

src/cli/rollout_cleanup.py:23

↓ 4 callersFunctionresolve_workspace_reference

Return best-effort workspace path for the given stage. Prefers archive_path, falls back to workspace. Emits warnings when missing.

src/pipelines/rollout_executor/scaling_success/workspace.py:18

↓ 4 callersMethodresult

(self, timeout: object | None = None)

tests/unit/scripts/test_rollout_llm_evaluator.py:29

↓ 4 callersMethodrun

(self, task: str)

src/cli/rollout_executor_cli.py:1533

↓ 4 callersMethodsave

(self)

src/pipelines/pr_combiner/review_queue.py:137

↓ 4 callersMethodtopic

Derive a topic label for grouping into chains.

src/pipelines/pr_combiner/models.py:112

↓ 4 callersFunctionwrite_template

(path: Path, template: str)

tests/unit/services/test_templates.py:9

↓ 3 callersMethod_aggregator_for_plan

(self, plan_id: str)

src/cli/rollout_executor_cli.py:402

↓ 3 callersMethod_auth_headers

(self, api_key: str)

src/services/sii_agent_client.py:76

↓ 3 callersFunction_build_mini_request

( task: QueryTask, *, credentials: Mapping[str, str], workspace_locator: WorkspaceLocator,

src/cli/rollout_executor_cli.py:1177

↓ 3 callersMethod_build_workspace_manager

(self, workspace_path: Path)

src/pipelines/rollout_executor/stage_session.py:1367

↓ 3 callersMethod_compose_prompt

(payload: Mapping[str, Any])

src/services/sii_agent_client.py:381

↓ 3 callersFunction_emit_progress

()

src/cli/rollout_executor_cli.py:3287

↓ 3 callersMethod_entry_path

(self, url: str, params: Mapping[str, Any] | None)

src/utils/cache.py:43

↓ 3 callersFunction_execute_tasks_concurrently

( tasks: List[QueryTask], base_executor: executor.RolloutExecutor, *, dry_run: bool, logge

src/cli/rollout_executor_cli.py:2622

↓ 3 callersFunction_extract_segment_text

Return trimmed text for a specific segment type/field from raw payload.

src/pipelines/pr_combiner/input_parser.py:188

↓ 3 callersFunction_group_stage_specs

( specs: Sequence[staged_queries.StageRunSpec], )

src/cli/rollout_executor_cli.py:2968

← previous next →101–200 of 2,118, ranked by callers