code: def test_op_raises_error_when_one_of_the_pipelines_is_broken(
      self,
  ) -> None:
      # Force a non-recoverable error.
      pipeline1 = read_text(pathname=" &^#").and_return()
      pipeline2 = read_text(pathname=" &^#").and_return()
  
      # Break the first pipeline.
      try:
          next(iter(pipeline1))
      except DataPipelineError:
          assert pipeline1.is_broken
  
      with pytest.raises(
          ValueError,
          match=r"^At least one of the specified data pipelines is broken and cannot be concatenated\.$",
      ):
          DataPipeline.concat([pipeline1, pipeline2]).and_return()
  
imports: import pytest
  from fairseq2.data import DataPipeline, DataPipelineError, read_sequence
  from fairseq2.data.text import read_text
label_desc: Use image node_id 3 for calling the TestConcatOp obj's underlying member method code with example usage: obj.test_op_raises_error_when_one_of_the_pipelines_is_broken() without return types