code: def shuffle_flow(request, temp_workspace):
      f = (
          Flow()
          .add(name="first")
          .add(
              uses=ConditionDumpExecutor,
              uses_metas={"name": "exec1"},
              workspace=os.environ["TEMP_WORKSPACE"],
              name="exec1",
              needs=["first"],
              when={
                  "$or": {
                      "tags__third": {"$eq": 1},
                      "tags__first": {"$eq": 1},
                      "tags__fourth": {"$eq": 1},
                  }
              },
          )
          .add(
              uses=ConditionDumpExecutor,
              uses_metas={"name": "exec2"},
              name="exec2",
              workspace=os.environ["TEMP_WORKSPACE"],
              needs="first",
              when={
                  "$or": {
                      "tags__second": {"$eq": 1},
                      "tags__fifth": {"$eq": 1},
                  }
              },
          )
          .needs_all("joiner")
      )
      return f
  
file_path: jina/tests/integration/conditions_feature/test_condition_behavior.py
imports: import os
  import pytest
  from docarray import Document, DocumentArray
  from jina import Executor, Flow, requests
label_desc: Use image node_id 2 for calling a global function with example usage: shuffle_flow(request, temp_workspace) and returns: f