code: def __init__(self, app: ext.ASGIApp, max_concurrency: int) -> None:
      self.app = app
      self._semaphore = asyncio.Semaphore(max_concurrency)
  
file_path: BentoML/src/bentoml/_internal/server/http/traffic.py
imports: from __future__ import annotations
  import asyncio
  from typing import TYPE_CHECKING
  import anyio
  from starlette.responses import PlainTextResponse
label_desc: Use image node_id 1 to create a new MaxConcurrencyMiddleware object  with example: obj = MaxConcurrencyMiddleware(app, max_concurrency)