Remove duplicate arguments in docstrings

elasticsearch/client/__init__.py

@@ -434,8 +434,6 @@ def bulk(self, body, index=None, doc_type=None, params=None, headers=None):
             the returned _source field, can be overridden on each sub-request
         :arg _source_includes: Default list of fields to extract and
             return from the _source field, can be overridden on each sub-request
-        :arg doc_type: Default document type for items which don't
-            provide one
         :arg pipeline: The pipeline id to preprocess incoming documents
             with
         :arg refresh: If `true` then refresh the affected shards to make
@@ -1293,7 +1291,6 @@ def put_script(self, id, body, context=None, params=None, headers=None):
 
         :arg id: Script ID
         :arg body: The document
-        :arg context: Script context
         :arg context: Context name to compile script against
         :arg master_timeout: Specify timeout for connection to master
         :arg timeout: Explicit operation timeout
@@ -1452,12 +1449,11 @@ def scroll(self, body=None, scroll_id=None, params=None, headers=None):
 
         :arg body: The scroll ID if not passed by URL or query
             parameter.
-        :arg scroll_id: The scroll ID
+        :arg scroll_id: The scroll ID for scrolled search
         :arg rest_total_hits_as_int: Indicates whether hits.total should
             be rendered as an integer or an object in the rest search response
         :arg scroll: Specify how long a consistent view of the index
             should be maintained for scrolled search
-        :arg scroll_id: The scroll ID for scrolled search
         """
         if scroll_id in SKIP_IN_PATH and body in SKIP_IN_PATH:
             raise ValueError("You need to supply scroll_id or body.")

elasticsearch/client/cat.py

@@ -243,8 +243,6 @@ def recovery(self, index=None, params=None, headers=None):
             yaml
         :arg h: Comma-separated list of column names to display
         :arg help: Return help information
-        :arg index: Comma-separated list or wildcard expression of index
-            names to limit the returned information
         :arg s: Comma-separated list of column names or column aliases
             to sort by
         :arg time: The unit in which to display time values  Valid
@@ -371,12 +369,10 @@ def fielddata(self, fields=None, params=None, headers=None):
         node in the cluster.
         `<https://www.elastic.co/guide/en/elasticsearch/reference/master/cat-fielddata.html>`_
 
-        :arg fields: A comma-separated list of fields to return the
-            fielddata size
-        :arg bytes: The unit in which to display byte values  Valid
-            choices: b, k, kb, m, mb, g, gb, t, tb, p, pb
         :arg fields: A comma-separated list of fields to return in the
             output
+        :arg bytes: The unit in which to display byte values  Valid
+            choices: b, k, kb, m, mb, g, gb, t, tb, p, pb
         :arg format: a short version of the Accept header, e.g. json,
             yaml
         :arg h: Comma-separated list of column names to display

elasticsearch/client/indices.py

@@ -12,7 +12,6 @@ def analyze(self, body=None, index=None, params=None, headers=None):
         :arg body: Define analyzer/tokenizer parameters and the text on
             which the analysis should be performed
         :arg index: The name of the index to scope the operation
-        :arg index: The name of the index to scope the operation
         """
         return self.transport.perform_request(
             "POST",
@@ -918,8 +917,6 @@ def clear_cache(self, index=None, params=None, headers=None):
             using the `fielddata` parameter (default: all)
         :arg ignore_unavailable: Whether specified concrete indices
             should be ignored when unavailable (missing or closed)
-        :arg index: A comma-separated list of index name to limit the
-            operation
         :arg query: Clear query caches
         :arg request: Clear request cache
         """

elasticsearch/client/watcher.py

@@ -149,9 +149,6 @@ def stats(self, metric=None, params=None, headers=None):
             current_watches, pending_watches
         :arg emit_stacktraces: Emits stack traces of currently running
             watches
-        :arg metric: Controls what additional stat metrics should be
-            include in the response  Valid choices: _all, queued_watches,
-            current_watches, pending_watches
         """
         return self.transport.perform_request(
             "GET",

utils/generate_api.py

@@ -171,11 +171,14 @@ def ind(item):
     @property
     def params(self):
         parts = self.all_parts
+        params = self._def.get("params", {})
         return chain(
             ((p, parts[p]) for p in parts if parts[p]["required"]),
-            (("body", self.body), ) if self.body else (),
-            ((p, parts[p]) for p in parts if not parts[p]["required"]),
-            sorted(self._def.get("params", {}).items()),
+            (("body", self.body),) if self.body else (),
+            ((p, parts[p]) for p in parts
+             if not parts[p]["required"] and
+             p not in params),
+            sorted(params.items(), key=lambda x: (x[0] not in parts, x[0])),
         )
 
     @property