code: def __init__(
      self,
      fn: Callable[[Any], None],
      inputs: Sequence[Any],
      chunk_size: Optional[int],
      chunk_bytes: Optional[Union[int, str]],
      compression: Optional[str],
  ):
      super().__init__(
          chunk_size=chunk_size,
          chunk_bytes=chunk_bytes,
          compression=compression,
      )
      self._fn = fn
      self._inputs = inputs
  
imports: import inspect
  import os
  from datetime import datetime
  from pathlib import Path
  from types import FunctionType
  from typing import Any, Callable, Dict, Optional, Sequence, Union
  import torch
  from lightning.data.streaming.constants import _LIGHTNING_CLOUD_LATEST, _TORCH_GREATER_EQUAL_2_1_0
  from lightning.data.streaming.data_processor import DataChunkRecipe, DataProcessor, DataTransformRecipe
label_desc: Use image node_id 1 to create a new LambdaDataChunkRecipe object from inherited base classes: DataChunkRecipe with example: obj = LambdaDataChunkRecipe(fn, inputs, chunk_size, chunk_bytes, compression)