utils#

Utility functions and helpers for OpenSTEF core functionality.

This package provides common utilities used throughout the OpenSTEF core library, including data serialization helpers, type conversion functions, and other general-purpose tools.

Submodules#

openstef_core.utils.datetime

Datetime manipulation utilities for time series alignment and processing.

openstef_core.utils.invariants

Runtime invariant checking utilities.

openstef_core.utils.itertools

Iterator utilities for data processing and stream merging.

openstef_core.utils.multiprocessing

Multiprocessing utilities for parallel execution of tasks.

openstef_core.utils.pandas

Pandas utility functions for time series data processing.

openstef_core.utils.pydantic

Pydantic-based utility functions for data serialization.

Functions#

align_datetime(timestamp, interval[, mode])

Align timestamp using modulo approach.

align_datetime_to_time(timestamp, align_time)

Align timestamp to the nearest occurrence of a specific time of day.

not_none(value)

Assert that a value is not None.

run_parallel(process_fn, items[, ...])

Execute a function in parallel across multiple processes.

timedelta_from_isoformat(s)

Convert ISO 8601 string format to timedelta.

timedelta_to_isoformat(td)

Convert timedelta to ISO 8601 string format.