MODULE REFERENCE

results

anomx.execution.results

Contracts shared by algorithm orchestrators.

JobResult

JobResult(job_id: str, status: str, connector: str, model: str, scorer: str, detector: str, summary: JobSummary, records: list[dict[str, Any]] = <factory: list>)

Signature parameters
Parameter	Type	Default
`job_id`	`str`	`required`
`status`	`str`	`required`
`connector`	`str`	`required`
`model`	`str`	`required`
`scorer`	`str`	`required`
`detector`	`str`	`required`
`summary`	`JobSummary`	`required`
`records`	`list[dict[str, Any]]`	`<factory: list>`

Members

job_idattribute

# JobResult.job_id Source ↗

job_id: str

statusattribute

# JobResult.status Source ↗

status: str

connectorattribute

# JobResult.connector Source ↗

connector: str

modelattribute

# JobResult.model Source ↗

model: str

scorerattribute

# JobResult.scorer Source ↗

scorer: str

detectorattribute

# JobResult.detector Source ↗

detector: str

summaryattribute

# JobResult.summary Source ↗

summary: JobSummary

recordsattribute

# JobResult.records Source ↗

records: list[dict[str, Any]] = field(default_factory=list)

to_dictmethod

# JobResult.to_dict Source ↗

to_dict() -> dict[str, Any]

Returns dict[str, Any]

classView source ↗

JobSpec

JobSpec(connector: str, model: str, detector: str, scorer: str, config: dict[str, Any] = <factory: dict>)

Signature parameters
Parameter	Type	Default
`connector`	`str`	`required`
`model`	`str`	`required`
`detector`	`str`	`required`
`scorer`	`str`	`required`
`config`	`dict[str, Any]`	`<factory: dict>`

Members

connectorattribute

# JobSpec.connector Source ↗

connector: str

modelattribute

# JobSpec.model Source ↗

model: str

detectorattribute

# JobSpec.detector Source ↗

detector: str

scorerattribute

# JobSpec.scorer Source ↗

scorer: str

configattribute

# JobSpec.config Source ↗

config: dict[str, Any] = field(default_factory=dict)

from_mappingclassmethod

# JobSpec.from_mapping Source ↗

from_mapping(payload: dict[str, Any]) -> JobSpec

Signature parameters
Parameter	Type	Default
`payload`	`dict[str, Any]`	`required`

Returns JobSpec

classView source ↗

JobSummary

JobSummary(rows_processed: int, anomaly_count: int, feature_columns: list[str] = <factory: list>, score_column: str = 'zscore', duration_ms: int = 0)

Signature parameters
Parameter	Type	Default
`rows_processed`	`int`	`required`
`anomaly_count`	`int`	`required`
`feature_columns`	`list[str]`	`<factory: list>`
`score_column`	`str`	`'zscore'`
`duration_ms`	`int`	`0`

Members

rows_processedattribute

# JobSummary.rows_processed Source ↗

rows_processed: int

anomaly_countattribute

# JobSummary.anomaly_count Source ↗

anomaly_count: int

feature_columnsattribute

# JobSummary.feature_columns Source ↗

feature_columns: list[str] = field(default_factory=list)

score_columnattribute

# JobSummary.score_column Source ↗

score_column: str = 'zscore'

duration_msattribute

# JobSummary.duration_ms Source ↗

duration_ms: int = 0