code: def __init__(self, operations: Sequence[Operation]):
      # This is the starting state of the pipeline
      self.original_state = State(
          jit_mode=True,
          device=ch.device("cpu"),
          dtype=np.dtype("u1"),
          shape=None,
      )
  
      self.operations = operations
  
      self.operation_blocks, _ = self.parse_pipeline()
      self.compiled_ops = self.compile_ops()
  
      # Compile the pipeline
      self.compiled_code = None
  
file_path: ffcv/ffcv/pipeline/pipeline.py
imports: from typing import Any, Optional, Sequence, Mapping
  import torch
  import numpy
  from .state import State
  from .operation import Operation
  from .allocation_query import Allocation, AllocationQuery
label_desc: Use image node_id 1 to create a new Pipeline object  with example: obj = Pipeline(operations)