code: def flow_run(flow, stop_event):
      with flow:
          flow.block(stop_event)
  
file_path: jina/tests/integration/reload/test_flow_reload.py
imports: import contextlib
  import os
  import shutil
  import threading
  import time
  import pytest
  from jina import Client, DocumentArray, Executor, Flow, requests
  from jina.helper import random_port
label_desc: Use image node_id 2 for calling a global function with example usage: flow_run(flow, stop_event) without return types