Functions — github.com/IBM/AssetOpsBench

hub / github.com/IBM/AssetOpsBench / functions

Functions947 in github.com/IBM/AssetOpsBench

⨍ Functions 947◇ Types & classes 171↳ Endpoints 13

↓ 4 callersFunctionaggregate_ops

(results: list[ScenarioResult])

src/evaluation/metrics.py:169

↓ 4 callersFunctionflatten_answer

Flatten nested structures into comparable key-value pairs.

src/evaluation/scorers/static_json.py:232

↓ 4 callersFunctioninit_tracing

Initialize the global OTEL tracer provider. Idempotent. No-op when tracing isn't configured, so callers can invoke unconditionally from CLI

src/observability/tracing.py:52

↓ 4 callersMethodlist_tools

List loaded tool names, optionally for one server (lazy-connects).

src/mcphub/__init__.py:236

↓ 4 callersFunctionload_trajectories

Load every ``*.json`` trajectory under ``path``. ``path`` may be a directory or a single JSON file. If a trajectory has ``scenario_id`` set t

src/evaluation/loader.py:15

↓ 4 callersMethodpredict

( self, y_pred, y_gt=None, X=None, timestamps=None, false_alarm=None, update=None )

src/servers/tsfm/anomaly.py:224

↓ 4 callersMethodput

Store a signal. Returns the data_id.

src/servers/vibration/data_store.py:99

↓ 4 callersMethodrun

Run the OpenAI Agents SDK loop for *question*. Args: question: Natural-language question to answer. Returns:

src/agent/openai_agent/runner.py:205

↓ 3 callersFunction_build_chat_model

Construct a LangChain chat model for *model_id*. When the ID uses a proxy-router prefix (``litellm_proxy/`` or ``tokenrouter/``), a :class:`C

src/agent/deep_agent/runner.py:41

↓ 3 callersFunction_build_mcp_config

Convert AssetOpsBench MCP server specs into OpenCode local MCP config.

src/agent/opencode_agent/runner.py:63

↓ 3 callersFunction_build_permissions

Build non-interactive permissions for benchmark-safe OpenCode runs.

src/agent/opencode_agent/runner.py:83

↓ 3 callersFunction_change_status

( db, wonum: str, site_id: str, new_status: str, extra: Optional[Dict[str, Any]] = None,

src/servers/wo/workorders.py:451

↓ 3 callersFunction_compact_spectrum

Summarise a spectrum: top-N peaks + global stats. No full arrays.

src/servers/vibration/main.py:66

↓ 3 callersMethod_connect

(self, server: str)

src/mcphub/__init__.py:257

↓ 3 callersFunction_content_text

Flatten Stirrup ``Content`` (``str | list[ContentBlock]``) to text.

src/agent/stirrup_agent/trajectory.py:50

↓ 3 callersFunction_copy_into_workspace

( *, source: Path, scenario_root: Path, workspace_dir: Path, )

src/benchmark/scenario_suite_runner.py:206

↓ 3 callersFunction_fake_client

(tools=None)

src/agent/deep_agent/tests/test_runner.py:226

↓ 3 callersFunction_get_dataset_path

(dataset: str)

src/servers/tsfm/io.py:32

↓ 3 callersFunction_get_model_checkpoint_path

(model_checkpoint: str)

src/servers/tsfm/io.py:24

↓ 3 callersFunction_load_model_config

Load and cache model config.json to avoid repeated disk reads.

src/servers/tsfm/main.py:79

↓ 3 callersFunction_make_composite

Composite signal with multiple sine components; returns data_id.

src/servers/vibration/tests/test_tools.py:34

↓ 3 callersFunction_print_section

(title: str)

src/agent/cli.py:73

↓ 3 callersFunction_resolve_signal

Return (1-D numpy signal, sample_rate) from a data_id.

src/servers/vibration/main.py:116

↓ 3 callersMethod_score_threshold_func

( self, cal_weights, cal_scores=None, y_pred=None, X=None, tim

src/servers/tsfm/anomaly.py:144

↓ 3 callersFunction_tool_part

(part_id, tool, *, input=None, output=None)

src/agent/opencode_agent/tests/test_runner.py:249

↓ 3 callersFunction_tsfm_data_quality_filter

( df_dataframe, dataset_config_dictionary, model_config, task="inference" )

src/servers/tsfm/forecasting.py:31

↓ 3 callersFunction_visible_text

Remove optional model thinking markup from user-facing text.

src/agent/opencode_agent/runner.py:364

↓ 3 callersFunctionextract_shaft_features

Extract amplitudes at shaft-frequency harmonics from a spectrum. Args: freqs: Frequency axis in Hz. magnitudes: Spectrum mag

src/servers/vibration/dsp/fault_detection.py:93

↓ 3 callersMethodgenerate

Generate text given a prompt.

src/llm/base.py:26

↓ 3 callersMethodgenerate

(self, prompt: str, temperature: float = 0.0)

src/agent/plan_execute/runner.py:47

↓ 3 callersFunctionget_bearing

Look up a bearing by its designation.

src/servers/vibration/dsp/bearing_freqs.py:181

↓ 3 callersMethodget_step

(self, number: int)

src/agent/plan_execute/models.py:29

↓ 3 callersMethodget_weights

(self, y_pred=None, X=None, timestamps=None, false_alarm=None)

src/servers/tsfm/anomaly.py:132

↓ 3 callersMethodopen

(self, name, cmd, env)

src/mcphub/__init__.py:131

↓ 3 callersMethodput

(self, doc)

src/servers/wo/tests/test_workorders.py:27

↓ 3 callersMethodremove

(self, data_id: str)

src/servers/vibration/data_store.py:128

↓ 3 callersFunctionrouter_prefix

Return the proxy-router prefix matching *model_id*, else ``None``.

src/llm/routers.py:45

↓ 3 callersFunctionscenario_dir_for_id

Return the expected scenario folder path for a scenario id.

src/benchmark/scenario_suite_runner.py:108

↓ 3 callersFunctionshow

(t, o)

examples/quickstart_tooluniverse.py:14

↓ 3 callersMethodto_dict

Return a JSON-serializable dictionary.

src/evaluation/scorers/static_json.py:61

↓ 3 callersFunctionwrite_reports_dir

Write one JSON file per result (``<run_id>.json``) plus an aggregate. Results without a ``run_id`` fall back to ``<scenario_id>.json`` so not

src/evaluation/report.py:148

↓ 2 callersFunction_build_opencode_config

Return (OpenCode config, env overrides, resolved OpenCode model).

src/agent/opencode_agent/runner.py:150

↓ 2 callersFunction_close_step

(input_tokens: int, output_tokens: int)

src/agent/opencode_agent/runner.py:444

↓ 2 callersFunction_derivatives

(inp, device="cpu")

src/servers/tsfm/metrics.py:190

↓ 2 callersFunction_df_nan_stats

(df, perc_rows_less_than=None, perc_rows_more_than=None)

src/servers/tsfm/dataquality.py:33

↓ 2 callersFunction_df_percentage_samples_minutes_interval

( df, date_col, lower_bound=14, upper_bound=16 )

src/servers/tsfm/dataquality.py:55

↓ 2 callersFunction_estimate_cost

(model: str, tokens_in: int, tokens_out: int)

src/evaluation/metrics.py:148

↓ 2 callersFunction_extract_count_from_text

Extract a count when the answer is count-only or nearly count-only.

src/evaluation/scorers/static_json.py:159

↓ 2 callersFunction_flatten

history is list[list[ChatMessage]]; flatten to a single message list.

src/agent/stirrup_agent/trajectory.py:89

↓ 2 callersFunction_flush

()

src/agent/openai_agent/runner.py:113

↓ 2 callersFunction_get_db

Lazy CouchDB connection with error handling.

src/servers/vibration/couchdb_client.py:28

↓ 2 callersFunction_get_gt_and_predictions

( trainer, dataset, ix_target_features, inverse_transforms=None )

src/servers/tsfm/forecasting.py:126

↓ 2 callersFunction_get_outputs_path

(outputs: str)

src/servers/tsfm/io.py:38

↓ 2 callersFunction_get_performance

( y_gt, y_pred, target_columns=None, prediction=True, inverse_transforms=None, ts_mask

src/servers/tsfm/forecasting.py:158

↓ 2 callersFunction_get_ttm_hf_inference

( df_dataframe, dataset_config_dictionary, model_config, model_checkpoint, scaling=False,

src/servers/tsfm/forecasting.py:219

↓ 2 callersFunction_http_endpoint_set

()

src/observability/tracing.py:39

↓ 2 callersFunction_install_file_exporter

(path: Path)

src/observability/tests/test_file_exporter.py:24

↓ 2 callersFunction_is_relative_to

(path: Path, base: Path)

src/benchmark/scenario_suite_runner.py:148

↓ 2 callersFunction_json_events

Parse OpenCode's JSON-lines event stream, preserving non-JSON lines.

src/agent/opencode_agent/runner.py:219

↓ 2 callersFunction_list_tools

Connect to an MCP server via stdio and list its tools with parameter info.

src/agent/plan_execute/executor.py:284

↓ 2 callersFunction_load_default_manifest

Return (manifest, base_dir) for the default manifest (scenarios_data/default/manifest.json).

src/couchdb/init_data.py:49

↓ 2 callersFunction_load_one_trajectory

(path: Path)

src/evaluation/loader.py:36

↓ 2 callersFunction_loss_helper

(outputs, targets, fn, axis=1)

src/servers/tsfm/metrics.py:91

↓ 2 callersFunction_make_stdio_params

Build StdioServerParameters for a server spec. - str → entry-point name; invoked as ``uv run <name>`` from the repo root. - Path → invoked a

src/agent/plan_execute/executor.py:257

↓ 2 callersFunction_mcp_session

Open an MCP session with anyio deadline enforcement. anyio.fail_after is used instead of asyncio.wait_for because anyio's cancel scopes propa

src/servers/vibration/tests/test_mcp_e2e.py:123

↓ 2 callersFunction_ms

(start: float | None, end: float | None)

src/agent/stirrup_agent/trajectory.py:82

↓ 2 callersFunction_names

(value)

src/mcphub/workflows.py:58

↓ 2 callersFunction_nonconformity_score_functions

( y_pred, y_gt, X=None, nonconformity_score="absolute_error" )

src/servers/tsfm/anomaly.py:30

↓ 2 callersFunction_normalize_model_id

(model_id: str | None)

src/evaluation/evaluator.py:118

↓ 2 callersFunction_percentile

(values: list[float], pct: float)

src/evaluation/metrics.py:186

↓ 2 callersMethod_qualify

(self, name: str)

src/mcphub/__init__.py:266

↓ 2 callersFunction_remove_df_nans

(df, p=50, dim="columns")

src/servers/tsfm/dataquality.py:148

↓ 2 callersFunction_safe_float

(value: Any)

src/evaluation/report.py:17

↓ 2 callersFunction_step_finish

(input_tokens, output_tokens)

src/agent/opencode_agent/tests/test_runner.py:264

↓ 2 callersFunction_system_from_model

Best-effort provider family from a model ID; returns ``"unknown"`` when the shape isn't recognized.

src/observability/runspan.py:37

↓ 2 callersFunction_traces_file_path

()

src/observability/tracing.py:35

↓ 2 callersFunction_tsad_output_to_df

(output: dict)

src/servers/tsfm/main.py:105

↓ 2 callersFunction_ttm_main_config

()

src/servers/tsfm/forecasting.py:351

↓ 2 callersFunction_unwrap

MCP CallToolResult -> plain Python value.

src/mcphub/__init__.py:46

↓ 2 callersFunction_usage_from_events

Extract token usage from OpenCode events. OpenCode emits per-step usage as ``tokens.input`` / ``tokens.output`` plus cache and reasoning buck

src/agent/opencode_agent/runner.py:323

↓ 2 callersFunction_weighted_conformal_quantile

( scores, weights, alpha=0.05, conformal_correction=False, max_score=np.inf )

src/servers/tsfm/anomaly.py:43

↓ 2 callersFunction_write_json_to_temp

(json_data: str)

src/servers/tsfm/io.py:47

↓ 2 callersFunctionbandpass_filter

Apply a Butterworth band-pass filter. Args: signal: Input time-domain signal. fs: Sampling frequency in Hz. low_hz:

src/servers/vibration/dsp/envelope.py:26

↓ 2 callersFunctioncheck_bearing_peaks

Check whether a target bearing frequency (and its harmonics) is present in an envelope spectrum. Args: freqs: Frequency axis (Hz

src/servers/vibration/dsp/envelope.py:123

↓ 2 callersFunctionclassify_faults

Apply rule-based classification for common rotating-machinery faults. Args: features: Extracted shaft-frequency features. be

src/servers/vibration/dsp/fault_detection.py:182

↓ 2 callersMethodclose

(self)

src/mcphub/__init__.py:174

↓ 2 callersFunctioncompute_envelope

Compute the amplitude envelope using the Hilbert transform. Args: signal: Input time-domain signal (ideally band-pass filtered).

src/servers/vibration/dsp/envelope.py:53

↓ 2 callersMethoddelete

(self, doc_id: str, rev: str)

src/servers/wo/couch.py:65

↓ 2 callersFunctionevaluate

Load, score, and aggregate. Per-scenario scorer is picked from ``scenario.scoring_method`` when set, falling back to ``default_scoring_method

src/evaluation/runner.py:11

↓ 2 callersFunctiongenerate_diagnosis_summary

Create a human-readable diagnosis summary. Args: diagnoses: List of FaultDiagnosis objects. iso_assessment: Optional ISO 108

src/servers/vibration/dsp/fault_detection.py:339

↓ 2 callersFunctionget_asset_doc

Fetch one asset-registry document, resolving ANY of the asset's id spaces — the registry `assetnum` (Maximo id), the telemetry `iot_asset_id`, or

src/servers/iot/main.py:196

↓ 2 callersMethodget_server_descriptions

Query each registered MCP server and return formatted tool signatures.

src/agent/plan_execute/executor.py:60

↓ 2 callersFunctionget_tracer

Return an OpenTelemetry :class:`Tracer`. When :func:`init_tracing` has not installed a provider, the returned tracer is OTel's built-in proxy

src/observability/tracing.py:117

↓ 2 callersFunctioninstall

src/evaluation/scorers/llm_judge.py:170

↓ 2 callersFunctionjoin_records

Yield (scenario, trajectory) pairs joined on ``scenario_id``.

src/evaluation/loader.py:146

↓ 2 callersFunctionknown_sites

The server's site list — discovered DYNAMICALLY from the asset registry (each asset profile's `siteid`). Falls back to DEFAULT_SITES only if the r

src/servers/iot/main.py:238

↓ 2 callersMethodlist

(self, name)

src/mcphub/__init__.py:134

↓ 2 callersFunctionlist_bearings

List all bearings in the database.

src/servers/vibration/dsp/bearing_freqs.py:186

↓ 2 callersMethodpredict_batch

( self, y_pred, y_gt=None, X=None, timestamps=None, false_alarm=None, update=None )

src/servers/tsfm/anomaly.py:176

↓ 2 callersFunctionregister

(name: str, scorer: Scorer)

src/evaluation/scorers/__init__.py:27

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