v0.9.2 (2026-03-27)

What’s new

Added

• Support for TableDataSource reader_kwargs attribute [#513]
• CustomWriter class and custom_writer field on BaseDataSink — fully replaces Laktory's built-in write logic with a user-supplied function; Laktory manages the streaming query lifecycle (foreachBatch, trigger, checkpoint) [#514]
• CustomDataSource source type and CustomReader class — fully user-supplied read function as a first-class source alongside FileDataSource, UnityCatalogDataSource, etc.
• LaktoryContext dataclass — runtime context object (node, pipeline, sink, source) optionally injected into user-supplied functions in CustomWriter, CustomReader, and DataFrameMethod by declaring laktory_context=None in the function signature [#515]

Fixed

• cluster.init_scripts.volumes property for Terraform (plural form instead of singular) [#516]
• Table properties not set before first write [#507]

Updated

• Pipeline node execution to include a creation step that facilitates injection of metadata before write data
• Improved tracking of Laktory-managed table properties
• DType and DataFrameSchema classes can be instantiated from Narwhals equivalent

Breaking changes

• n/a

Full Changelog