code: def test_this_will_fail(protocol):
      f = (
          Flow(protocol=protocol)
          .add(name="a11", uses="DummySegment")
          .add(name="a12", uses="DummySegment", needs="gateway")
          .add(name="r1", needs=["a11", "a12"])
          .add(name="a21", uses="DummySegment", needs="gateway")
          .add(name="a22", uses="DummySegment", needs="gateway")
          .add(name="r2", needs=["a21", "a22"])
          .add(needs=["r1", "r2"])
      )
  
      with f:
          da = f.index(inputs=random_docs(10, chunks_per_doc=0))
  
      validate(da)
  
file_path: jina/tests/unit/orchestrate/flow/flow-orchestrate/test_flow_merge.py
imports: import random
  import pytest
  from jina import Flow, Executor, requests, Document
  from tests import random_docs, validate_callback
label_desc: Use image node_id 2 for calling a global function with example usage: test_this_will_fail(protocol) without return types