code: def test_selective_pipeline_selects_transforms_and_does_the_fusion():
      ppl = slc.SelectiveStream(
          [
              slt.Rotate(angle_range=(90, 90), p=1),
              slt.Rotate(angle_range=(-90, -90), p=1),
          ],
          n=2,
          probs=[0.5, 0.5],
          optimize_stack=True,
      )
  
      kpts_data = np.array([[0, 0], [0, 1], [1, 0], [1, 1]]).reshape(
          (4, 2)
      )
      kpts = slc.Keypoints(kpts_data, 3, 4)
      dc = slc.DataContainer(kpts, "P")
      dc_res = ppl(dc, return_torch=False)
  
      assert np.array_equal(
          np.eye(3), ppl.transforms[0].state_dict["transform_matrix"]
      )
  
imports: import itertools
  import random
  import cv2
  import numpy
  import pytest
  import torch
  import solt.core
  import solt.transforms
  import solt.utils
  from .fixtures import *
label_desc: Use image node_id 26 for calling a global function with example usage: test_selective_pipeline_selects_transforms_and_does_the_fusion() without return types