code: def assert_op(streams, expected):
      feed = DataFeed(streams)
      feed.compile()
  
      actual = []
      while feed.has_next():
          d = feed.next()
  
          v = None
          for k in d.keys():
              if v is None:
                  v = d[k]
              else:
                  assert d[k] == v
          actual += [v]
  
      np.testing.assert_allclose(actual, expected)
  
label_desc: Use image node_id 1 for calling a global function with example usage: assert_op(streams, expected) without return types