diff --git a/elasticsearch/_async/client/logstash.py b/elasticsearch/_async/client/logstash.py index 1de847fa5..e6e7adc27 100644 --- a/elasticsearch/_async/client/logstash.py +++ b/elasticsearch/_async/client/logstash.py @@ -62,7 +62,7 @@ async def delete_pipeline( async def get_pipeline( self, *, - id: t.Union[str, t.Sequence[str]], + id: t.Optional[t.Union[str, t.Sequence[str]]] = None, error_trace: t.Optional[bool] = None, filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None, human: t.Optional[bool] = None, @@ -75,8 +75,6 @@ async def get_pipeline( :param id: Comma-separated list of pipeline identifiers. """ - 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: diff --git a/elasticsearch/_sync/client/logstash.py b/elasticsearch/_sync/client/logstash.py index f00591a5e..018376684 100644 --- a/elasticsearch/_sync/client/logstash.py +++ b/elasticsearch/_sync/client/logstash.py @@ -62,7 +62,7 @@ def delete_pipeline( def get_pipeline( self, *, - id: t.Union[str, t.Sequence[str]], + id: t.Optional[t.Union[str, t.Sequence[str]]] = None, error_trace: t.Optional[bool] = None, filter_path: t.Optional[t.Union[str, t.Sequence[str]]] = None, human: t.Optional[bool] = None, @@ -75,8 +75,6 @@ def get_pipeline( :param id: Comma-separated list of pipeline identifiers. """ - 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: