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

↓ 3 callersFunction_json_stringify

(value: Any)

src/pipelines/data_process/openai_json_stringify.py:97

↓ 3 callersFunction_load_for_query

(query: str)

tests/integration/test_planner.py:14

↓ 3 callersMethod_load_plan

(self, plan_id: str, repository_hint: Optional[str] = None)

src/pipelines/rollout_executor/stage_config.py:91

↓ 3 callersFunction_load_stage_specs

Attempt to load staged rollout specifications, returning empty list when unavailable.

src/cli/rollout_executor_cli.py:2913

↓ 3 callersFunction_log_revision_feedback

(logger, run_id: str)

src/cli/rollout_executor_cli.py:4071

↓ 3 callersFunction_make_entry

(session_id: str, base_dir: Path)

tests/unit/pipelines/rollout_executor/test_registry_concurrency.py:80

↓ 3 callersFunction_make_rollout_config

(tmp_path: Path)

tests/integration/rollout_executor/test_mini_scaffold.py:22

↓ 3 callersMethod_plan_state_path

(self, plan_id: str)

src/pipelines/rollout_executor/stage_session.py:1485

↓ 3 callersFunction_populate_references

( detail: PRDetails, *, evidence_context: int, client: "GitHubClient" | None, telemetry: "

src/pipelines/pr_combiner/input_parser.py:265

↓ 3 callersFunction_print_turn_history

(turns: Sequence)

src/cli/rollout_executor_cli.py:4023

↓ 3 callersFunction_prioritize_fail_case_stage_groups

( groups: Sequence[Sequence[staged_queries.StageRunSpec]], success_plans: set[str], )

src/cli/rollout_executor_cli.py:2305

↓ 3 callersFunction_prioritize_fail_case_tasks

( tasks: Sequence[QueryTask], success_plans: set[str], )

src/cli/rollout_executor_cli.py:2288

↓ 3 callersFunction_provenance

( *, source_url: str = "https://github.com/example/repo/pull/101", api_url: str = "https://api.git

tests/unit/pipelines/pr_combiner/test_timeline_provenance.py:8

↓ 3 callersFunction_push

(value: Optional[str])

src/pipelines/pr_combiner/input_parser.py:215

↓ 3 callersMethod_refresh

(self)

src/cli/rollout_executor_ui.py:298

↓ 3 callersFunction_resolve_concurrency

(requested: int, task_count: int)

src/cli/rollout_executor_cli.py:815

↓ 3 callersFunction_resolve_path

(raw_path: str, base_dir: Path)

src/pipelines/domain_analysis/llm_topic_classifier.py:691

↓ 3 callersFunction_resolve_rollout_directory

( *, requested_path: str | None, base_dir: Path, repo_slug: str | None, now: datetime | No

src/cli/rollout_executor_cli.py:2143

↓ 3 callersFunction_resolve_template_path

(entry: Dict[str, Any])

src/services/prompt_loader.py:50

↓ 3 callersFunction_rollouts_root

(config: RolloutExecutionConfig)

src/pipelines/rollout_executor/persistence.py:1052

↓ 3 callersFunction_select_execution_concurrency

( flag_value: int | None, task_count: int, logger, )

src/cli/rollout_executor_cli.py:825

↓ 3 callersMethod_split_paths

(self, payload: str)

src/pipelines/rollout_executor/git_workspace.py:331

↓ 3 callersFunction_stage_execution_dir

(plan_id: str, config: RolloutExecutionConfig)

src/pipelines/rollout_executor/persistence.py:157

↓ 3 callersFunction_stage_ledger_path

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

src/pipelines/rollout_executor/persistence.py:207

↓ 3 callersFunction_token_count

( tokenizer: ChatTokenizer, messages: List[Dict[str, Any]], tools: List[Dict[str, Any]], )

src/pipelines/data_process/pipeline_utils.py:91

↓ 3 callersFunction_touch

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

tests/unit/cli/test_mini_scaling_success_resume_demo.py:13

↓ 3 callersFunction_touch

(path: Path)

tests/unit/scripts/test_rollout_llm_evaluator.py:38

↓ 3 callersFunction_validate_candidate

(path: Path)

src/services/runtime/sii_bridge.py:13

↓ 3 callersFunction_write_file

(path: Path, suffix: str)

tests/unit/cli/test_rollout_executor_cli.py:60

↓ 3 callersFunction_write_registry

(path: Path, *, entry: dict[str, object])

tests/unit/scripts/test_rollout_llm_evaluator.py:34

↓ 3 callersFunction_write_rollout

(path: Path, user: int, internal: int, total: int | None = None)

tests/unit/cli/test_rollout_stats_cli.py:12

↓ 3 callersFunction_write_summary

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

tests/unit/utils/test_domain_analysis_rollup.py:15

↓ 3 callersFunctionacquire_session_lock

Acquire a session-specific file lock, yielding the lock object.

src/pipelines/rollout_executor/session_lock.py:14

↓ 3 callersMethodapply_chat_template

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

src/utils/parquet_token_counter.py:26

↓ 3 callersMethodapply_patch

Apply a patch using three-way merge; optionally force-preferring patch contents.

src/pipelines/rollout_executor/git_workspace.py:129

↓ 3 callersFunctionarchive_workspace

Archive a workspace directory to dest. - Prefer reflink/hardlink if supported (cp --reflink=auto). - Falls back to shutil.copytree with

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

↓ 3 callersMethodbuild_ground_truth

( self, *, session_id: str, plan_id: str, stage_spec: StageRunSpec,

src/pipelines/rollout_executor/stage_session.py:1549

↓ 3 callersFunctionbuild_repository_index

Construct an index of PR numbers per repository for quick lookups.

src/pipelines/pr_combiner/reference_parser.py:31

↓ 3 callersMethodbuild_sequence_entry

Return a synthetic taxonomy entry based on commit types.

src/pipelines/domain_analysis/llm_topic_classifier.py:90

↓ 3 callersMethodclear_conversation_logs

Remove prior `.sii/conversation_logs` files before a new agent run.

src/pipelines/rollout_executor/git_workspace.py:81

↓ 3 callersMethodcomplete_session

Mark a session complete, mirror transcripts, and register metadata.

src/pipelines/rollout_executor/session.py:172

↓ 3 callersFunctioncompute_ratios

Return ratios for counts, normalized by the total count.

src/utils/domain_analysis_rollup.py:93

↓ 3 callersFunctioncompute_summary

( runs: Iterable[AgentRun], statuses: Dict[str, EnvironmentStatus], )

src/services/reporting/rollout_summary.py:77

↓ 3 callersFunctionconvert_json_to_parquet

( *, tokenizer_path: str, input_json: str, output_parquet: str, max_tokens: int = 128000,

src/pipelines/data_process/messages_json2parquet_128k.py:26

↓ 3 callersFunctionformat_elapsed

Format elapsed seconds into a short human-readable string.

src/utils/logger.py:130

↓ 3 callersMethodfrom_inputs

( cls, *, flag_value: str | None, env: Mapping[str, str] | None = None, )

src/cli/rollout_executor_ui.py:56

↓ 3 callersMethodget_export

(self, run_id: str)

src/services/api/relationship_combiner.py:20

↓ 3 callersMethodget_json

Fetch JSON from the GitHub API with caching, retries, and rate-limit awareness.

src/pipelines/pr_combiner/github_client.py:37

↓ 3 callersMethodget_profile

(self, auth_type: Optional[str] = None)

src/utils/config.py:443

↓ 3 callersMethodget_stage_execution_audit

Retrieve audit data for a specific stage execution.

src/services/api/rollouts.py:107

↓ 3 callersMethodget_transcript

Public helper returning session and ordered turns.

src/pipelines/rollout_executor/session.py:251

↓ 3 callersMethodload_result_payload

(path: Path)

src/cli/rollout_executor_cli.py:308

↓ 3 callersFunctionmake_chain

()

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

↓ 3 callersFunctionmake_detail

(pr_number: int, segments: list[dict])

tests/unit/pipelines/pr_combiner/test_input_parser.py:43

↓ 3 callersFunctionmake_run

( run_id: str, template_id: str, status: str, duration_seconds: float, alerts: list[str] |

tests/unit/services/test_rollout_reporting.py:7

↓ 3 callersFunctionmake_staged_artifact

Assemble a StagedQueryArtifact from provided stages.

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

↓ 3 callersFunctionmake_template_yaml

(template_id: str, description: str)

tests/unit/services/test_templates.py:13

↓ 3 callersFunctionparse_timestamp

Parse ISO8601 timestamp to aware datetime in UTC; return None if missing.

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

↓ 3 callersMethodpublish_reasoning_coverage

Publish aggregated reasoning coverage for a session.

src/services/telemetry_stream.py:203

↓ 3 callersMethodpublish_revision_switch

Publish a revision switch lifecycle event.

src/services/telemetry_stream.py:178

↓ 3 callersMethodpublish_rollout_mode

Publish rollout executor mode transitions (fallback, sequential, concurrent).

src/services/telemetry_stream.py:226

↓ 3 callersMethodrecord_decision

( self, relationship_id: str, *, reviewer: str, resolution: str,

src/pipelines/pr_combiner/review_queue.py:118

↓ 3 callersFunctionrecord_to_messages

Convert a single record with ``instruction``/``output`` into messages.

src/pipelines/data_process/instruction_output_json_to_parquet.py:106

↓ 3 callersFunctionresolve_registry_entry

Resolve the rollouts.json registry entry that corresponds to a rollout artifact. Primary lookup: - dataset artifact filenames that embed th

src/services/reporting/rollout_dataset_stats.py:248

↓ 3 callersMethodresolve_revision

Resolve a revision to a full commit SHA, raising if invalid.

src/pipelines/rollout_executor/git_workspace.py:100

↓ 3 callersMethodroute

Route alerts for the run, emitting telemetry events for new entries.

src/services/alerts.py:41

↓ 3 callersMethodrun

(self, request)

tests/unit/cli/test_rollout_executor_cli.py:523

↓ 3 callersFunctionrun_scaling_success

Main entrypoint returning formatted outputs for scaling-success.

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

↓ 3 callersMethodrun_with_timeout

Execute mini-swe-agent with a hard timeout and persist a trajectory on timeout. The upstream mini agent only writes a trajectory after comple

src/services/mini_swe_runner.py:160

↓ 3 callersMethodset

Persist the payload for the given request signature.

src/utils/cache.py:82

↓ 3 callersMethodsnapshot

(self)

src/cli/rollout_executor_ui.py:284

↓ 3 callersMethodstop

(self)

src/cli/rollout_executor_ui.py:184

↓ 3 callersMethodupdate_progress

Update rollout stats. Returns True if UI handled logging.

src/cli/rollout_executor_ui.py:209

↓ 3 callersFunctionwrite_json

Serialize payload to JSON at the given path.

src/services/artifact_store.py:32

↓ 3 callersFunctionwrite_json_atomic

(path: Path, payload: Any)

src/pipelines/rollout_executor/persistence.py:1128

↓ 3 callersFunctionwrite_output

(data: List[Dict[str, Any]], output_path: Path, indent: int)

src/pipelines/data_process/convert_to_openai.py:346

↓ 2 callersFunction_analyze_single

Safely analyze a single chain with error handling.

src/cli/domain_analysis_cli.py:107

↓ 2 callersMethod_annotate_reasoning

(self, path: Path)

src/services/mini_swe_runner.py:522

↓ 2 callersFunction_audit_log_dir

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

src/pipelines/rollout_executor/persistence.py:1014

↓ 2 callersMethod_build_agent

(self, request: MiniSweRunRequest)

src/services/mini_swe_runner.py:435

↓ 2 callersMethod_build_attempt_summary

( self, attempt_index: int, attempt_result: StageAttemptResult, evaluation: St

src/pipelines/rollout_executor/stage_session.py:591

↓ 2 callersMethod_build_chain_domain

Derive chain domain by concatenating PR commit types in order.

src/pipelines/domain_analysis/llm_topic_classifier.py:544

↓ 2 callersMethod_build_failed_result

( self, *, spec: staged_queries.StageRunSpec, plan_id: str, attempt_in

src/cli/rollout_executor_cli.py:536

↓ 2 callersFunction_build_orchestrator

()

src/cli/rollout_executor_cli.py:1342

↓ 2 callersFunction_build_request

( repo: Path, mode: DiffMode, pr_records: list[PRRecordSummary], *, backend: DiffBackend =

tests/unit/services/test_rollout_diff.py:46

↓ 2 callersMethod_build_run

( self, *, spec: staged_queries.StageRunSpec, attempt_index: int, stat

src/cli/rollout_executor_cli.py:493

↓ 2 callersFunction_build_stage_orchestrator

( exec_instance: executor.RolloutExecutor, )

src/cli/rollout_executor_cli.py:3697

↓ 2 callersFunction_build_toy_tokenizer

(root: Path)

tests/integration/test_rollup_parquet_token_stats_cli.py:16

↓ 2 callersFunction_build_toy_tokenizer

(root: Path)

tests/integration/test_plot_openai_data_token_distribution.py:14

↓ 2 callersFunction_build_toy_tokenizer

(root: Path)

tests/unit/utils/test_parquet_token_counter.py:15

↓ 2 callersMethod_build_transcript

( self, *, plan_id: str, stage_id: str, attempt_index: int, st

src/cli/rollout_executor_cli.py:437

↓ 2 callersMethod_call_health_check

(self, *, base: str, api_key: str, timeout: float)

src/services/sii_agent_client.py:98

↓ 2 callersMethod_capture_conversation_log

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

src/pipelines/rollout_executor/stage_session.py:787

↓ 2 callersFunction_clamp

(value: int, *, lower: int, upper: int)

src/cli/rollout_executor_ui.py:33

↓ 2 callersFunction_coerce_attempt_index

(value: Any)

src/pipelines/data_process/mini_swe_converter.py:112

↓ 2 callersMethod_coerce_path

(path: Path | str)

src/pipelines/domain_analysis/data_loader.py:83

↓ 2 callersFunction_collect_critical_files

Return a de-duplicated ordered list of files referenced by patches.

src/pipelines/rollout_executor/staged_queries.py:65

↓ 2 callersFunction_collect_github_patches

(files: Iterable[dict[str, Any]])

src/services/rollout_diff/generator.py:214

↓ 2 callersFunction_collect_local_patches

(git: _GitRunner, base_commit: str, head_commit: str)

src/services/rollout_diff/generator.py:290

↓ 2 callersFunction_collect_reference_texts

(detail: PRDetails)

src/pipelines/pr_combiner/input_parser.py:211

← previous next →201–300 of 2,118, ranked by callers