code: def test_filter_multistream(idtype):
      # this is a smoke test to ensure we do not trip any internal assertions
      import torch
  
      s = torch.cuda.Stream(device=F.ctx())
      with torch.cuda.stream(s):
          # we must do multiple runs such that the stream is busy as we launch
          # work
          for i in range(10):
              f = Filter(
                  F.arange(1000, 4000, dtype=idtype, ctx=F.ctx())
              )
              x = F.randint(
                  [30000], dtype=idtype, ctx=F.ctx(), low=0, high=50000
              )
              xi = f.find_included_indices(x)
  
file_path: dgl/tests/python/common/utils/test_filter.py
imports: import unittest
  import backend
  import dgl
  import numpy
  from dgl.utils import Filter
  from utils import parametrize_idtype
label_desc: Use image node_id 3 for calling a global function with example usage: test_filter_multistream(idtype) without return types