code: def test_op_works(self) -> None:
      def fn(d: int) -> bool:
          return d % 2 == 1
  
      pipeline = (
          read_sequence([1, 2, 3, 4, 5, 6, 7, 8, 9])
          .filter(fn)
          .and_return()
      )
  
      for _ in range(2):
          assert list(pipeline) == [1, 3, 5, 7, 9]
  
          pipeline.reset()
  
imports: import pytest
  from fairseq2.data import DataPipelineError, read_sequence
label_desc: Use image node_id 1 for calling the TestFilterOp obj's underlying member method code with example usage: obj.test_op_works() and returns: unknown