code: def test_streaming_streamable_functions(
      monkeypatch: Any, capfd: Any
  ) -> None:
      monkeypatch.setenv("POLARS_VERBOSE", "1")
      assert (
          pl.DataFrame({"a": [1, 2, 3]})
          .lazy()
          .map_batches(
              function=lambda df: df.with_columns(
                  pl.col("a").alias("b")
              ),
              schema={"a": pl.Int64, "b": pl.Int64},
              streamable=True,
          )
      ).collect(streaming=True).to_dict(as_series=False) == {
          "a": [1, 2, 3],
          "b": [1, 2, 3],
      }
  
      (_, err) = capfd.readouterr()
      assert "df -> function -> ordered_sink" in err
  
imports: from __future__ import annotations
  import os
  import tempfile
  import time
  from datetime import date
  from pathlib import Path
  from typing import TYPE_CHECKING, Any
  import numpy
  import pytest
  import polars
  from polars.exceptions import PolarsInefficientMapWarning
  from polars.testing import assert_frame_equal
label_desc: Use image node_id 3 for calling a global function with example usage: test_streaming_streamable_functions(monkeypatch, capfd) without return types