diff --git a/elasticsearch/_async/client/tasks.py b/elasticsearch/_async/client/tasks.py index 0acbfef31..9bc545834 100644 --- a/elasticsearch/_async/client/tasks.py +++ b/elasticsearch/_async/client/tasks.py @@ -197,7 +197,7 @@ async def list( if master_timeout is not None: __query["master_timeout"] = master_timeout if node_id is not None: - __query["node_id"] = node_id + __query["nodes"] = node_id if parent_task_id is not None: __query["parent_task_id"] = parent_task_id if pretty is not None: diff --git a/elasticsearch/_sync/client/tasks.py b/elasticsearch/_sync/client/tasks.py index a0c4a742d..622036211 100644 --- a/elasticsearch/_sync/client/tasks.py +++ b/elasticsearch/_sync/client/tasks.py @@ -197,7 +197,7 @@ def list( if master_timeout is not None: __query["master_timeout"] = master_timeout if node_id is not None: - __query["node_id"] = node_id + __query["nodes"] = node_id if parent_task_id is not None: __query["parent_task_id"] = parent_task_id if pretty is not None: