code: def test_streaming_block_on_literals_6054() -> None:
      df = pl.DataFrame({"col_1": [0] * 5 + [1] * 5})
      s = pl.Series("col_2", list(range(10)))
  
      assert df.lazy().with_columns(s).group_by("col_1").agg(
          pl.all().first()
      ).collect(streaming=True).sort("col_1").to_dict(
          as_series=False
      ) == {
          "col_1": [0, 1],
          "col_2": [0, 5],
      }
  
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 2 for calling a global function with example usage: test_streaming_block_on_literals_6054() without return types