dlt.extract.incremental.sql

to_sqlglot_filter

def to_sqlglot_filter(
    incremental: "Incremental[Any]",
    apply_lag: bool = True,
    destination_capabilities: Optional[DestinationCapabilitiesContext] = None
) -> Optional[sge.Expression]

View source on GitHub

Build a sqlglot WHERE expression that filters rows to the current incremental window.

Arguments:

• incremental Incremental[Any] - Incremental instance whose cursor is filtered. Works on bound and unbound instances.
• apply_lag bool - When True, lag is applied to the lower bound; when False, the raw cached start_value is used.
• destination_capabilities Optional[DestinationCapabilitiesContext] - Caps used to shape the timestamp cast and literal format (precision, tz handling, sqlite cast drop). When None, a generic tz-aware cast is emitted.

Returns:

• Optional[sge.Expression] - A sqlglot boolean expression suitable for use as a WHERE clause, or None when filtering is not possible.