async def METHOD_NAME(
    self,
    *,
    id: t.Union[str, t.Union[t.List[str], t.Tuple[str, ...]]],
    error_trace: t.Optional[bool] = None,
    filter_path: t.Optional[
        t.Union[str, t.Union[t.List[str], t.Tuple[str, ...]]]
    ] = None,
    human: t.Optional[bool] = None,
    pretty: t.Optional[bool] = None,
) -> ObjectApiResponse[t.Any]:
    """
    Retrieves Logstash Pipelines used by Central Management
    `<https://www.elastic.co/guide/en/elasticsearch/reference/master/logstash-api-get-pipeline.html>`_
    :param id: A comma-separated list of Pipeline IDs
    """
    if id in SKIP_IN_PATH:
        raise ValueError("Empty value passed for parameter 'id'")
    if id not in SKIP_IN_PATH:
        __path = f"/_logstash/pipeline/{_quote(id)}"
    else:
        __path = "/_logstash/pipeline"
    __query: t.Dict[str, t.Any] = {}
    if error_trace is not None:
        __query["error_trace"] = error_trace
    if filter_path is not None:
        __query["filter_path"] = filter_path
    if human is not None:
        __query["human"] = human
    if pretty is not None:
        __query["pretty"] = pretty
    __headers = {"accept": "application/json"}
    return await self.perform_request(  # type: ignore[return-value]
        "GET", __path, params=__query, headers=__headers
    )