code: def __init__(
      self, fn: Callable[[str, Any], None], inputs: Sequence[Any]
  ):
      super().__init__()
      self._fn = fn
      self._inputs = inputs
      self._device: Optional[str] = None
  
      _fn = self._fn if isinstance(self._fn, FunctionType) else self._fn.__call__  # type: ignore
      params = inspect.signature(_fn).parameters
      self._contains_device = "device" in params
  
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 LambdaDataTransformRecipe object from inherited base classes: DataTransformRecipe with example: obj = LambdaDataTransformRecipe(fn, inputs)