obelisk.asynchronous.core.ChunkedParams

class obelisk.asynchronous.core.ChunkedParams(*, dataset: str, groupBy: List[str] | None = None, aggregator: Literal['last', 'min', 'mean', 'max', 'count', 'stddev'] | None = None, fields: List[str] | None = None, orderBy: List[str] | None = None, dataType: Literal['number', 'number[]', 'json', 'bool', 'string'] | None = None, filter_: str | Filter | None = None, start: datetime, end: datetime, jump: timedelta = datetime.timedelta(seconds=3600))

Bases: BaseModel

__init__(**data: Any) → None

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

Methods

check_datatype_needed() → Self

chunks() → Iterator[QueryParams]

Attributes

model_config: ClassVar[ConfigDict] = {'arbitrary_types_allowed': True}

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

dataset: str

groupBy: List[str] | None

aggregator: Literal['last', 'min', 'mean', 'max', 'count', 'stddev'] | None

fields: List[str] | None

orderBy: List[str] | None

dataType: Literal['number', 'number[]', 'json', 'bool', 'string'] | None

filter_: str | Filter | None

Underscore suffix to avoid name collisions

start: datetime

end: datetime

jump: timedelta