code: def test_pod_in_flow_activates_shards_replicas():
      shards = 2
      replicas = 3
      args_list = [
          "--replicas",
          str(replicas),
          "--shards",
          str(shards),
          "--no-reduce",
      ]
      args = set_deployment_parser().parse_args(args_list)
      args.uses = "SetNameExecutor"
      with Deployment(args, include_gateway=False) as pod:
          assert pod.num_pods == 7
          response_texts = set()
          # replicas and shards are used in a round robin fashion, so sending 6 requests should hit each one time
          for _ in range(6):
              response = send_request_sync(
                  _create_test_data_message(),
                  f"{pod.head_args.host}:{pod.head_args.port[0]}",
              )
              response_texts.update(response.response.docs.texts)
          print(response_texts)
          assert 6 == len(response_texts)
          assert all(
              text in response_texts
              for text in [
                  f"executor/shard-{s}/rep-{r}"
                  for s in range(shards)
                  for r in range(replicas)
              ]
          )
  
      Deployment(args, include_gateway=False).start().close()
  
imports: import json
  import os
  import pytest
  import yaml
  from jina import Document, DocumentArray, Executor, requests
  from jina.clients.request import request_generator
  from jina.constants import __default_executor__, __default_host__
  from jina.enums import PollingType
  from jina.excepts import RuntimeFailToStart
  from jina.orchestrate.deployments import Deployment
  from jina.parsers import set_deployment_parser, set_gateway_parser
  from jina.serve.networking.utils import send_request_sync
  from tests.unit.test_helper import MyDummyExecutor
label_desc: Use image node_id 15 for calling a global function with example usage: test_pod_in_flow_activates_shards_replicas() without return types