diff | Kitaru Reference

Execution diff utilities for replay comparison.

attributeDEFAULT_COMPARE_FLOW_VERSION

= 'local'

CheckpointDiff

ExecutionDiff

funccompare_urls_for_replay(client, *, original_exec_id, replay_exec_id) -> list[str]

Build UI compare URLs for one original execution and its replay.

paramclientKitaruClient

paramoriginal_exec_idstr

paramreplay_exec_idstr

Returns

list[str]

funcbuild_compare_url_for_executions

(*, flow_id, exec_ids, server_url=None, flow_version=DEFAULT_COMPARE_FLOW_VERSION, project_name_or_id=None, ui_context=None) -> str | None

Build a Kitaru UI compare URL for two or more executions.

Example::

{server}/flows/{flow_id}/v/local/compare?executions={id1},{id2},{id3}

paramflow_idstr | None

paramexec_idsSequence[str]

paramserver_urlstr | None

= None

paramflow_versionstr

= DEFAULT_COMPARE_FLOW_VERSION

paramproject_name_or_idstr | None

= None

paramui_contextUiUrlContext | None

= None

Returns

str | None

funcbuild_compare_url

(*, flow_id, original_exec_id, replay_exec_id, server_url=None, flow_version=DEFAULT_COMPARE_FLOW_VERSION, project_name_or_id=None, ui_context=None) -> str | None

Build the Kitaru UI compare URL for an original vs one replay execution.

Example::

{server}/flows/{flow_id}/v/local/compare?executions={original},{replay}

paramflow_idstr | None

paramoriginal_exec_idstr

paramreplay_exec_idstr

paramserver_urlstr | None

= None

paramflow_versionstr

= DEFAULT_COMPARE_FLOW_VERSION

paramproject_name_or_idstr | None

= None

paramui_contextUiUrlContext | None

= None

Returns

str | None

funccompare_url_for_executions(exec_ids, *, client=None) -> str | None

Build one UI compare URL from explicit execution IDs (2 or more).

paramexec_idsSequence[str]

paramclientKitaruClient | None

= None

Returns

str | None

funcbuild_compare_urls

(*, flow_id, original_exec_id, replay_exec_ids, server_url=None, flow_version=DEFAULT_COMPARE_FLOW_VERSION, project_name_or_id=None, ui_context=None) -> list[str]

Build one UI compare URL per original-vs-replay pair.

paramflow_idstr | None

paramoriginal_exec_idstr

paramreplay_exec_idsSequence[str]

paramserver_urlstr | None

= None

paramflow_versionstr

= DEFAULT_COMPARE_FLOW_VERSION

paramproject_name_or_idstr | None

= None

paramui_contextUiUrlContext | None

= None

Returns

list[str]

funcserialize_checkpoint_diff(item) -> dict[str, Any]

paramitemCheckpointDiff

Returns

dict[str, typing.Any]

funcserialize_execution_diff(item) -> dict[str, Any]

paramitemExecutionDiff

Returns

dict[str, typing.Any]

funcserialize_diff_matrix(item) -> dict[str, Any]

paramitemCohortDiff

Returns

dict[str, typing.Any]

funcdiff(original, *executions) -> ExecutionDiff

Compare an original execution against replay executions.

When executions is omitted, all runs whose original_exec_id matches original are included.

paramoriginalstr

paramexecutionsstr

= ()

Returns

kitaru.diff.ExecutionDiff

funcdiff_matrix(exec_ids) -> CohortDiff

Compare many original executions against their discovered replays.

paramexec_idsSequence[str] | Any

Returns

kitaru.diff.CohortDiff