def METHOD_NAME(
    self, txn: LoggingTransaction
) -> int:
    return self.db_pool.simple_select_one_onecol_txn(
        txn,
        table="current_state_delta_stream",
        keyvalues={},
        retcol="COALESCE(MAX(stream_id), -1)",
    )