monitor_schema.models

Console script for monitor_schema.

Subpackages

• monitor_schema.models.analyzer
  • monitor_schema.models.analyzer.algorithms
  • monitor_schema.models.analyzer.analyzer
  • monitor_schema.models.analyzer.baseline
  • monitor_schema.models.analyzer.targets

Submodules

• monitor_schema.models.column_schema
• monitor_schema.models.commons
• monitor_schema.models.document
• monitor_schema.models.monitor
• monitor_schema.models.segments
• monitor_schema.models.utils

Package Contents

Classes

DatasetMetric	Metrics that are applicable at the dataset level.
SimpleColumnMetric	Simple column metrics that are basically just a single number.
ComplexMetrics	Sketch-based metrics that can only be processed by certain algorithms.
Analyzer	Configuration for running an analysis.
BaselineType	Supported baseline types.
ReferenceProfileId	A baseline based on a static reference profile.
TimeRangeBaseline	A static time range.
TrailingWindowBaseline	A dynamic trailing window.
SingleBatchBaseline	Using current batch.
DriftConfig	An analyzer using stddev for a window of time range.
DiffConfig	Detecting the differences between two numerical metrics.
ComparisonConfig	Compare whether the target against a value or against a baseline's metric.
ExperimentalConfig	Experimental algorithm that is not standardized by the above ones yet.
FixedThresholdsConfig	Fixed threshold analysis.
ColumnListChangeConfig	Compare whether the target is equal to a value or not.
SeasonalConfig	An analyzer using stddev for a window of time range.
StddevConfig	Calculates upper bounds and lower bounds based on stddev from a series of numbers.
DatasetMatrix	Define the matrix of fields and segments to fan out for monitoring.
ColumnMatrix	Define the matrix of columns and segments to fan out for monitoring.
TargetLevel	Which nested level we are targeting.
Metadata	Metadata for a top-level objects such as monitors, analyzers, and schema.
Segment	A segment is a list of tags.
ColumnDiscreteness	Classifying the type.
ColumnDataType	Options for configuring data type for a column.
ColumnSchema	Schema configuration for a column.
WeightConfig	Object that specifies column weights.
SegmentWeightConfig	Object that specifies column weights for a segment.
EntitySchema	Schema definition of an entity.
ImmediateSchedule	Schedule the monitor to run immediately.
CronSchedule	Support for scheduling.
Cadence	Cadence for an analyzer or monitor run.
FixedCadenceSchedule	Support for scheduling based on a predefined cadence.
Metadata	Metadata for a top-level objects such as monitors, analyzers, and schema.
Analyzer	Configuration for running an analysis.
EntitySchema	Schema definition of an entity.
Metadata	Metadata for a top-level objects such as monitors, analyzers, and schema.
Monitor	Customer specified monitor configs.
Granularity	Supported granularity.
Document	The main document that dictates how the monitor should be run. This document is managed by WhyLabs internally.
CronSchedule	Support for scheduling.
FixedCadenceSchedule	Support for scheduling based on a predefined cadence.
ImmediateSchedule	Schedule the monitor to run immediately.
Metadata	Metadata for a top-level objects such as monitors, analyzers, and schema.
GlobalAction	Actions that are configured at the team/organization level.
SendEmail	Action to send an email.
SlackWebhook	Action to send a Slack webhook.
RawWebhook	Action to send a Slack webhook.
AnomalyFilter	Filter the anomalies based on certain criteria. If the alerts are filtered down to 0, the monitor won't fire.
EveryAnomalyMode	Config mode that indicates the monitor will send out individual messages per anomaly.
DigestMode	Config mode that indicates the monitor will send out a digest message.
Monitor	Customer specified monitor configs.
SegmentTag	A single tag key value pair for a segment.
Segment	A segment is a list of tags.

class monitor_schema.models.DatasetMetric

Bases: str, enum.Enum

Metrics that are applicable at the dataset level.

profile_count = profile.count

profile_last_ingestion_time = profile.last_ingestion_time

profile_first_ingestion_time = profile.first_ingestion_time

column_row_count_sum = column_row_count_sum

shape_column_count = shape_column_count

shape_row_count = shape_row_count

input_count = input.count

output_count = output.count

classification_f1 = classification.f1

classification_precision = classification.precision

classification_recall = classification.recall

classification_accuracy = classification.accuracy

classification_auc = classification.auc

regression_mse = regression.mse

regression_mae = regression.mae

regression_rmse = regression.rmse

class monitor_schema.models.SimpleColumnMetric

Bases: str, enum.Enum

Simple column metrics that are basically just a single number.

count = count

median = median

max = max

min = min

mean = mean

stddev = stddev

variance = variance

unique_upper = unique_upper

unique_upper_ratio = unique_upper_ratio

unique_est = unique_est

unique_est_ratio = unique_est_ratio

unique_lower = unique_lower

unique_lower_ratio = unique_lower_ratio

count_bool = count_bool

count_bool_ratio = count_bool_ratio

count_integral = count_integral

count_integral_ratio = count_integral_ratio

count_fractional = count_fractional

count_fractional_ratio = count_fractional_ratio

count_string = count_string

count_string_ratio = count_string_ratio

count_null = count_null

count_null_ratio = count_null_ratio

inferred_data_type = inferred_data_type

quantile_p5 = quantile_5

quantile_p75 = quantile_75

quantile_p25 = quantile_25

quantile_p90 = quantile_90

quantile_p95 = quantile_95

quantile_p99 = quantile_99

class monitor_schema.models.ComplexMetrics

Bases: str, enum.Enum

Sketch-based metrics that can only be processed by certain algorithms.

histogram = histogram

frequent_items = frequent_items

unique_sketch = unique_sketch

column_list = column_list

class monitor_schema.models.Analyzer(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Configuration for running an analysis.

An analysis targets a metric (note that a metric could be a complex object) for one or multiple fields in one or multiple segments. The output is a list of ‘anomalies’ that might show issues with data.

class Config

Updates JSON schema anyOf to oneOf.

static schema_extra(schema: Dict[str, Any], model: pydantic.BaseModel) → None

Update specific fields here (for Union type, specifically).

metadata :Optional[monitor_schema.models.commons.Metadata]

id :str

displayName :Optional[str]

tags :Optional[List[constr(min_length=3, max_length=32, regex='[0-9a-zA-Z\\-_]')]]

schedule :Optional[Union[monitor_schema.models.commons.CronSchedule, monitor_schema.models.commons.FixedCadenceSchedule]]

disabled :Optional[bool]

targetMatrix :Union[monitor_schema.models.analyzer.targets.ColumnMatrix, monitor_schema.models.analyzer.targets.DatasetMatrix]

dataReadinessDuration :Optional[str]

batchCoolDownPeriod :Optional[str]

backfillGracePeriodDuration :Optional[str]

config :Union[monitor_schema.models.analyzer.algorithms.DiffConfig, monitor_schema.models.analyzer.algorithms.ComparisonConfig, monitor_schema.models.analyzer.algorithms.ListComparisonConfig, monitor_schema.models.analyzer.algorithms.ColumnListChangeConfig, monitor_schema.models.analyzer.algorithms.FixedThresholdsConfig, monitor_schema.models.analyzer.algorithms.StddevConfig, monitor_schema.models.analyzer.algorithms.DriftConfig, monitor_schema.models.analyzer.algorithms.ExperimentalConfig, monitor_schema.models.analyzer.algorithms.SeasonalConfig]

class monitor_schema.models.BaselineType

Bases: str, enum.Enum

Supported baseline types.

BatchTimestamp = BatchTimestamp

Reference = Reference

TrailingWindow = TrailingWindow

TimeRange = TimeRange

CurrentBatch = CurrentBatch

class monitor_schema.models.ReferenceProfileId(**data: Any)

Bases: _Baseline

A baseline based on a static reference profile.

A typical use case is to use a “gold” dataset and upload its profile to WhyLabs. This can be a training dataset as well for an ML model.

type :Literal[BaselineType]

profileId :str

class monitor_schema.models.TimeRangeBaseline(**data: Any)

Bases: _SegmentBaseline

A static time range.

Instead of using a single profile or a trailing window, user can lock in a “good” period.

type :Literal[BaselineType]

range :monitor_schema.models.commons.TimeRange

class monitor_schema.models.TrailingWindowBaseline(**data: Any)

Bases: _SegmentBaseline

A dynamic trailing window.

This is useful if you don’t have a static baseline to monitor against. This is the default mode for most monitors.

type :Literal[BaselineType]

size :int

offset :Optional[int]

exclusionRanges :Optional[List[monitor_schema.models.commons.TimeRange]]

class monitor_schema.models.SingleBatchBaseline(**data: Any)

Bases: _SegmentBaseline

Using current batch.

This is used when you want to use one batch to monitor another batch in a different metric entity.

type :Literal[BaselineType]

offset :Optional[int]

datasetId :str

class monitor_schema.models.DriftConfig(**data: Any)

Bases: AlgorithmConfig

An analyzer using stddev for a window of time range.

This analysis will detect whether the data drifts or not. By default, we use hellinger distance with a threshold of 0.7.

type :Literal[AlgorithmType]

algorithm :Literal[hellinger, ks_test, kl_divergence, variation_distance]

metric :Literal[ComplexMetrics, ComplexMetrics]

threshold :float

minBatchSize :Optional[int]

baseline :Union[monitor_schema.models.analyzer.baseline.TrailingWindowBaseline, monitor_schema.models.analyzer.baseline.ReferenceProfileId, monitor_schema.models.analyzer.baseline.TimeRangeBaseline, monitor_schema.models.analyzer.baseline.SingleBatchBaseline]

class monitor_schema.models.DiffConfig(**data: Any)

Bases: AlgorithmConfig

Detecting the differences between two numerical metrics.

type :Literal[AlgorithmType]

mode :DiffMode

thresholdType :Optional[ThresholdType]

threshold :float

baseline :Union[monitor_schema.models.analyzer.baseline.TrailingWindowBaseline, monitor_schema.models.analyzer.baseline.ReferenceProfileId, monitor_schema.models.analyzer.baseline.TimeRangeBaseline, monitor_schema.models.analyzer.baseline.SingleBatchBaseline]

class monitor_schema.models.ComparisonConfig(**data: Any)

Bases: AlgorithmConfig

Compare whether the target against a value or against a baseline’s metric.

This is useful to detect data type change, for instance.

type :Literal[AlgorithmType]

operator :ComparisonOperator

expected :Optional[ExpectedValue]

baseline :Optional[Union[monitor_schema.models.analyzer.baseline.TrailingWindowBaseline, monitor_schema.models.analyzer.baseline.ReferenceProfileId, monitor_schema.models.analyzer.baseline.TimeRangeBaseline, monitor_schema.models.analyzer.baseline.SingleBatchBaseline]]

class monitor_schema.models.ExperimentalConfig(**data: Any)

Bases: AlgorithmConfig

Experimental algorithm that is not standardized by the above ones yet.

type :Literal[AlgorithmType]

implementation :str

baseline :Union[monitor_schema.models.analyzer.baseline.TrailingWindowBaseline, monitor_schema.models.analyzer.baseline.ReferenceProfileId, monitor_schema.models.analyzer.baseline.TimeRangeBaseline, monitor_schema.models.analyzer.baseline.SingleBatchBaseline]

stub :Optional[AlgorithmType]

class monitor_schema.models.FixedThresholdsConfig(**data: Any)

Bases: AlgorithmConfig

Fixed threshold analysis.

If user fails to set both upper bound and lower bound, this algorithm becomes a no-op. WhyLabs might enforce the present of either fields in the future.

type :Literal[AlgorithmType]

upper :Optional[float]

lower :Optional[float]

class monitor_schema.models.ColumnListChangeConfig(**data: Any)

Bases: AlgorithmConfig

Compare whether the target is equal to a value or not.

This is useful to detect data type change, for instance.

type :Literal[AlgorithmType]

mode :Literal[ON_ADD_AND_REMOVE, ON_ADD, ON_REMOVE] = ON_ADD_AND_REMOVE

metric :Literal[ComplexMetrics]

exclude :Optional[List[monitor_schema.models.utils.COLUMN_NAME_TYPE]]

baseline :Union[monitor_schema.models.analyzer.baseline.TrailingWindowBaseline, monitor_schema.models.analyzer.baseline.ReferenceProfileId, monitor_schema.models.analyzer.baseline.TimeRangeBaseline, monitor_schema.models.analyzer.baseline.SingleBatchBaseline]

class monitor_schema.models.SeasonalConfig(**data: Any)

Bases: _ThresholdBaseConfig

An analyzer using stddev for a window of time range.

This will fall back to Poisson distribution if there is only 1 value in the baseline.

This only works with TrailingWindow baseline (TODO: add backend validation)

type :Literal[AlgorithmType]

algorithm :Literal[arima, rego, stastforecast]

minBatchSize :Optional[int]

alpha :Optional[float]

baseline :monitor_schema.models.analyzer.baseline.TrailingWindowBaseline

stddevTimeRanges :Optional[List[monitor_schema.models.commons.TimeRange]]

stddevMaxBatchSize :Optional[int]

stddevFactor :Optional[float]

class monitor_schema.models.StddevConfig(**data: Any)

Bases: _ThresholdBaseConfig

Calculates upper bounds and lower bounds based on stddev from a series of numbers.

An analyzer using stddev for a window of time range.

This calculation will fall back to Poisson distribution if there is only 1 value in the baseline. For 2 values, we use the formula sqrt((x_i - avg(x))^2 / n - 1)

type :Literal[AlgorithmType]

factor :Optional[float]

minBatchSize :Optional[int]

baseline :Union[monitor_schema.models.analyzer.baseline.TrailingWindowBaseline, monitor_schema.models.analyzer.baseline.TimeRangeBaseline, monitor_schema.models.analyzer.baseline.ReferenceProfileId]

class monitor_schema.models.DatasetMatrix(**data: Any)

Bases: _BaseMatrix

Define the matrix of fields and segments to fan out for monitoring.

.

type :Literal[TargetLevel]

class monitor_schema.models.ColumnMatrix(**data: Any)

Bases: _BaseMatrix

Define the matrix of columns and segments to fan out for monitoring.

type :Literal[TargetLevel]

include :Optional[List[Union[ColumnGroups, monitor_schema.models.utils.COLUMN_NAME_TYPE]]]

exclude :Optional[List[Union[ColumnGroups, monitor_schema.models.utils.COLUMN_NAME_TYPE]]]

class monitor_schema.models.TargetLevel

Bases: str, enum.Enum

Which nested level we are targeting.

dataset = dataset

column = column

class monitor_schema.models.Metadata(**data: Any)

Bases: NoExtrasBaseModel

Metadata for a top-level objects such as monitors, analyzers, and schema.

This object is managed by WhyLabs. Any user-provided values will be ignored on WhyLabs side.

version :int

schemaVersion :Optional[int]

updatedTimestamp :int

author :str

description :Optional[str]

class monitor_schema.models.Segment(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

A segment is a list of tags.

We normalize these in the backend.

tags :List[SegmentTag]

class monitor_schema.models.ColumnDiscreteness

Bases: str, enum.Enum

Classifying the type.

discrete = discrete

continuous = continuous

class monitor_schema.models.ColumnDataType

Bases: str, enum.Enum

Options for configuring data type for a column.

integral = integral

fractional = fractional

boolean = bool

string = string

unknown = unknown

null = null

class monitor_schema.models.ColumnSchema(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Schema configuration for a column.

Should be generated by WhyLabs originally but can be overridden by users.

discreteness :ColumnDiscreteness

dataType :ColumnDataType

classifier :Optional[str]

class monitor_schema.models.WeightConfig(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Object that specifies column weights.

• By default, the weight of a column is None (unspecified)

• If the weight is unspecified, the column is EXCLUDED when you perform a filter/sort by weight

• For sorting, unweighted column take the LEAST PRECEDENCE, meaning that weight column have higher priorities

• They are not hierarchical: if a segment weight config is specified and a column does not have a weight in that

config, we will not use any hierarchy to resolve the value. It will be None - Order of unweighted column is undefined.

weights :Dict[monitor_schema.models.utils.COLUMN_NAME_TYPE, float]

class monitor_schema.models.SegmentWeightConfig(**data: Any)

Bases: WeightConfig

Object that specifies column weights for a segment.

segment :Optional[monitor_schema.models.segments.Segment]

class monitor_schema.models.EntitySchema(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Schema definition of an entity.

metadata :Optional[monitor_schema.models.commons.Metadata]

columns :Dict[monitor_schema.models.utils.COLUMN_NAME_TYPE, ColumnSchema]

class monitor_schema.models.ImmediateSchedule(**data: Any)

Bases: NoExtrasBaseModel

Schedule the monitor to run immediately.

type :Literal[immediate]

class monitor_schema.models.CronSchedule(**data: Any)

Bases: NoExtrasBaseModel

Support for scheduling.

type :Literal[CronSchedule.cron]

cron :str

exclusionRanges :Optional[List[TimeRange]]

class monitor_schema.models.Cadence

Bases: str, enum.Enum

Cadence for an analyzer or monitor run.

hourly = hourly

daily = daily

weekly = weekly

monthly = monthly

class monitor_schema.models.FixedCadenceSchedule(**data: Any)

Bases: NoExtrasBaseModel

Support for scheduling based on a predefined cadence.

type :Literal[fixed]

cadence :Literal[Cadence, Cadence, Cadence, Cadence]

exclusionRanges :Optional[List[TimeRange]]

class monitor_schema.models.Metadata(**data: Any)

Bases: NoExtrasBaseModel

Metadata for a top-level objects such as monitors, analyzers, and schema.

This object is managed by WhyLabs. Any user-provided values will be ignored on WhyLabs side.

version :int

schemaVersion :Optional[int]

updatedTimestamp :int

author :str

description :Optional[str]

class monitor_schema.models.Analyzer(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Configuration for running an analysis.

An analysis targets a metric (note that a metric could be a complex object) for one or multiple fields in one or multiple segments. The output is a list of ‘anomalies’ that might show issues with data.

class Config

Updates JSON schema anyOf to oneOf.

static schema_extra(schema: Dict[str, Any], model: pydantic.BaseModel) → None

Update specific fields here (for Union type, specifically).

metadata :Optional[monitor_schema.models.commons.Metadata]

id :str

displayName :Optional[str]

tags :Optional[List[constr(min_length=3, max_length=32, regex='[0-9a-zA-Z\\-_]')]]

schedule :Optional[Union[monitor_schema.models.commons.CronSchedule, monitor_schema.models.commons.FixedCadenceSchedule]]

disabled :Optional[bool]

targetMatrix :Union[monitor_schema.models.analyzer.targets.ColumnMatrix, monitor_schema.models.analyzer.targets.DatasetMatrix]

dataReadinessDuration :Optional[str]

batchCoolDownPeriod :Optional[str]

backfillGracePeriodDuration :Optional[str]

config :Union[monitor_schema.models.analyzer.algorithms.DiffConfig, monitor_schema.models.analyzer.algorithms.ComparisonConfig, monitor_schema.models.analyzer.algorithms.ListComparisonConfig, monitor_schema.models.analyzer.algorithms.ColumnListChangeConfig, monitor_schema.models.analyzer.algorithms.FixedThresholdsConfig, monitor_schema.models.analyzer.algorithms.StddevConfig, monitor_schema.models.analyzer.algorithms.DriftConfig, monitor_schema.models.analyzer.algorithms.ExperimentalConfig, monitor_schema.models.analyzer.algorithms.SeasonalConfig]

class monitor_schema.models.EntitySchema(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Schema definition of an entity.

metadata :Optional[monitor_schema.models.commons.Metadata]

columns :Dict[monitor_schema.models.utils.COLUMN_NAME_TYPE, ColumnSchema]

class monitor_schema.models.Metadata(**data: Any)

Bases: NoExtrasBaseModel

Metadata for a top-level objects such as monitors, analyzers, and schema.

This object is managed by WhyLabs. Any user-provided values will be ignored on WhyLabs side.

version :int

schemaVersion :Optional[int]

updatedTimestamp :int

author :str

description :Optional[str]

class monitor_schema.models.Monitor(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Customer specified monitor configs.

class Config

Updates JSON schema anyOf to oneOf.

static schema_extra(schema: Dict[str, Any], model: pydantic.BaseModel) → None

Update specific fields here (for Union type, specifically).

metadata :Optional[monitor_schema.models.commons.Metadata]

id :str

displayName :Optional[str]

tags :Optional[List[constr(min_length=3, max_length=32, regex='[0-9a-zA-Z\\-_]')]]

analyzerIds :List[constr(regex='^[A-Za-z0-9_\\-]+$')]

schedule :Union[monitor_schema.models.commons.FixedCadenceSchedule, monitor_schema.models.commons.CronSchedule, monitor_schema.models.commons.ImmediateSchedule]

disabled :Optional[bool]

severity :Optional[int]

mode :Union[EveryAnomalyMode, DigestMode]

actions :List[Union[GlobalAction, SendEmail, SlackWebhook, RawWebhook]]

class monitor_schema.models.Granularity

Bases: str, enum.Enum

Supported granularity.

hourly = hourly

daily = daily

weekly = weekly

monthly = monthly

class monitor_schema.models.Document(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

The main document that dictates how the monitor should be run. This document is managed by WhyLabs internally.

id :Optional[uuid.UUID]

schemaVersion :Literal[1]

metadata :Optional[monitor_schema.models.commons.Metadata]

orgId :str

datasetId :str

granularity :Granularity

allowPartialTargetBatches :Optional[bool]

entitySchema :Optional[monitor_schema.models.column_schema.EntitySchema]

weightConfig :Optional[monitor_schema.models.column_schema.EntityWeights]

analyzers :List[monitor_schema.models.analyzer.Analyzer]

monitors :List[monitor_schema.models.monitor.Monitor]

class monitor_schema.models.CronSchedule(**data: Any)

Bases: NoExtrasBaseModel

Support for scheduling.

type :Literal[CronSchedule.cron]

cron :str

exclusionRanges :Optional[List[TimeRange]]

class monitor_schema.models.FixedCadenceSchedule(**data: Any)

Bases: NoExtrasBaseModel

Support for scheduling based on a predefined cadence.

type :Literal[fixed]

cadence :Literal[Cadence, Cadence, Cadence, Cadence]

exclusionRanges :Optional[List[TimeRange]]

class monitor_schema.models.ImmediateSchedule(**data: Any)

Bases: NoExtrasBaseModel

Schedule the monitor to run immediately.

type :Literal[immediate]

class monitor_schema.models.Metadata(**data: Any)

Bases: NoExtrasBaseModel

Metadata for a top-level objects such as monitors, analyzers, and schema.

This object is managed by WhyLabs. Any user-provided values will be ignored on WhyLabs side.

version :int

schemaVersion :Optional[int]

updatedTimestamp :int

author :str

description :Optional[str]

class monitor_schema.models.GlobalAction(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Actions that are configured at the team/organization level.

type :Literal[global]

target :str

class monitor_schema.models.SendEmail(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Action to send an email.

type :Literal[email]

target :str

class monitor_schema.models.SlackWebhook(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Action to send a Slack webhook.

type :Literal[slack]

target :pydantic.HttpUrl

class monitor_schema.models.RawWebhook(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Action to send a Slack webhook.

type :Literal[raw]

target :pydantic.HttpUrl

class monitor_schema.models.AnomalyFilter(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Filter the anomalies based on certain criteria. If the alerts are filtered down to 0, the monitor won’t fire.

includeColumns :Optional[List[monitor_schema.models.utils.COLUMN_NAME_TYPE]]

excludeColumns :Optional[List[monitor_schema.models.utils.COLUMN_NAME_TYPE]]

minWeight :Optional[float]

maxWeight :Optional[float]

minRankByWeight :Optional[int]

maxRankByWeight :Optional[int]

minTotalWeight :Optional[float]

maxTotalWeight :Optional[float]

minAlertCount :Optional[int]

maxAlertCount :Optional[int]

includeMetrics :Optional[List[monitor_schema.models.utils.METRIC_NAME_STR]]

class monitor_schema.models.EveryAnomalyMode(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Config mode that indicates the monitor will send out individual messages per anomaly.

type :Literal[EVERY_ANOMALY]

filter :Optional[AnomalyFilter]

class monitor_schema.models.DigestMode(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Config mode that indicates the monitor will send out a digest message.

type :Literal[DIGEST]

filter :Optional[AnomalyFilter]

creationTimeOffset :Optional[str]

datasetTimestampOffset :Optional[str]

groupBy :Optional[List[DigestModeGrouping]]

class monitor_schema.models.Monitor(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

Customer specified monitor configs.

class Config

Updates JSON schema anyOf to oneOf.

static schema_extra(schema: Dict[str, Any], model: pydantic.BaseModel) → None

Update specific fields here (for Union type, specifically).

metadata :Optional[monitor_schema.models.commons.Metadata]

id :str

displayName :Optional[str]

tags :Optional[List[constr(min_length=3, max_length=32, regex='[0-9a-zA-Z\\-_]')]]

analyzerIds :List[constr(regex='^[A-Za-z0-9_\\-]+$')]

schedule :Union[monitor_schema.models.commons.FixedCadenceSchedule, monitor_schema.models.commons.CronSchedule, monitor_schema.models.commons.ImmediateSchedule]

disabled :Optional[bool]

severity :Optional[int]

mode :Union[EveryAnomalyMode, DigestMode]

actions :List[Union[GlobalAction, SendEmail, SlackWebhook, RawWebhook]]

class monitor_schema.models.SegmentTag(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

A single tag key value pair for a segment.

key :str

value :str

class monitor_schema.models.Segment(**data: Any)

Bases: monitor_schema.models.commons.NoExtrasBaseModel

A segment is a list of tags.

We normalize these in the backend.

tags :List[SegmentTag]