code: def flow():
      f = (
          Flow(
              protocol="http",
              port_expose=PORT_EXPOSE,
              expose_graphql_endpoint=True,
          )
          .add(uses=GraphQLTestEncoder, name="Encoder")
          .add(uses=GraphQLTestIndexer, name="Indexer")
          .add(uses=SlowExec)
      )
      with f:
          f.index(
              inputs=(
                  Document(text=t.strip())
                  for t in open(__file__)
                  if t.strip()
              )
          )
          yield
  
imports: import asyncio
  import time
  import urllib.error
  from typing import Dict
  import numpy
  import pytest
  from docarray.array.document import DocumentArray
  from docarray.document import Document
  from jina import Client, Executor, Flow, requests
label_desc: Use image node_id 1 for calling a global function with example usage: flow() without return types