code: def test_map_items_to_workers_sequentially(monkeypatch):
      workers_user_items = _map_items_to_workers_sequentially(
          1, list(range(5))
      )
      assert workers_user_items == [list(range(5))]
      workers_user_items = _map_items_to_workers_sequentially(
          2, list(range(5))
      )
      assert workers_user_items == [[0, 1], [2, 3, 4]]
      workers_user_items = _map_items_to_workers_sequentially(
          3, list(range(5))
      )
      assert workers_user_items == [[0], [1], [2, 3, 4]]
      workers_user_items = _map_items_to_workers_sequentially(
          4, list(range(5))
      )
      assert workers_user_items == [[0], [1], [2], [3, 4]]
  
      monkeypatch.setenv("DATA_OPTIMIZER_NUM_NODES", "2")
      monkeypatch.setenv("DATA_OPTIMIZER_NODE_RANK", "0")
      workers_user_items = _map_items_to_workers_sequentially(
          1, list(range(5))
      )
      assert workers_user_items == [[0, 1]]
      workers_user_items = _map_items_to_workers_sequentially(
          2, list(range(5))
      )
      assert workers_user_items == [[0], [1]]
  
      monkeypatch.setenv("DATA_OPTIMIZER_NUM_NODES", "2")
      monkeypatch.setenv("DATA_OPTIMIZER_NODE_RANK", "1")
      workers_user_items = _map_items_to_workers_sequentially(
          1, list(range(5))
      )
      assert workers_user_items == [[2, 3, 4]]
      workers_user_items = _map_items_to_workers_sequentially(
          2, list(range(5))
      )
      assert workers_user_items == [[2], [3, 4]]
  
      monkeypatch.setenv("DATA_OPTIMIZER_NUM_NODES", "4")
      monkeypatch.setenv("DATA_OPTIMIZER_NODE_RANK", "0")
      workers_user_items = _map_items_to_workers_sequentially(
          1, list(range(32))
      )
      assert workers_user_items == [[0, 1, 2, 3, 4, 5, 6, 7]]
      workers_user_items = _map_items_to_workers_sequentially(
          2, list(range(32))
      )
      assert workers_user_items == [[0, 1, 2, 3], [4, 5, 6, 7]]
      workers_user_items = _map_items_to_workers_sequentially(
          3, list(range(32))
      )
      assert workers_user_items == [[0, 1], [2, 3], [4, 5, 6, 7]]
      workers_user_items = _map_items_to_workers_sequentially(
          4, list(range(32))
      )
      assert workers_user_items == [[0, 1], [2, 3], [4, 5], [6, 7]]
  
      monkeypatch.setenv("DATA_OPTIMIZER_NUM_NODES", "4")
      monkeypatch.setenv("DATA_OPTIMIZER_NODE_RANK", "3")
      workers_user_items = _map_items_to_workers_sequentially(
          1, list(range(32))
      )
      assert workers_user_items == [[24, 25, 26, 27, 28, 29, 30, 31]]
      workers_user_items = _map_items_to_workers_sequentially(
          2, list(range(32))
      )
      assert workers_user_items == [[24, 25, 26, 27], [28, 29, 30, 31]]
      workers_user_items = _map_items_to_workers_sequentially(
          3, list(range(32))
      )
      assert workers_user_items == [
          [24, 25],
          [26, 27],
          [28, 29, 30, 31],
      ]
      workers_user_items = _map_items_to_workers_sequentially(
          4, list(range(32))
      )
      assert workers_user_items == [
          [24, 25],
          [26, 27],
          [28, 29],
          [30, 31],
      ]
  
imports: import os
  import random
  import sys
  from typing import Any, List
  from unittest import mock
  import lightning_cloud
  import numpy
  import pytest
  import torch
  from lightning import seed_everything
  from lightning.data.streaming import data_processor
  from lightning.data.streaming import functions
  from lightning.data.streaming.cache import Cache, Dir
  from lightning.data.streaming.data_processor import DataChunkRecipe, DataProcessor, DataTransformRecipe, _download_data_target, _get_item_filesizes, _map_items_to_workers_sequentially, _map_items_to_workers_weighted, _remove_target, _upload_fn, _wait_for_disk_usage_higher_than_threshold, _wait_for_file_to_exist
  from lightning.data.streaming.functions import LambdaDataTransformRecipe, map, optimize
  from lightning_cloud import resolver
  from lightning_utilities.core.imports import RequirementCache
label_desc: Use image node_id 9 for calling a global function with example usage: test_map_items_to_workers_sequentially(monkeypatch) without return types