code: def input_docs():
      return DocumentArray([Document() for _ in range(50)])
  
file_path: jina/tests/integration/distributed-replicas/test_distributed_replicas.py
imports: import os
  import time
  import pytest
  from docarray import Document, DocumentArray
  from jina import Flow
  from jina.helper import random_port
  from jina.orchestrate.deployments import Deployment
  from jina.parsers import set_deployment_parser
label_desc: Use image node_id 2 for calling a global function with example usage: input_docs() and returns: DocumentArray