Add the cluster.pending_tasks api

2014-01-17 14:39:04 +01:00
parent 9b7797d5c8
commit 3298e1082f
1 changed files with 12 additions and 0 deletions
@@ -23,6 +23,18 @@ class ClusterClient(NamespacedClient):
            params=params)
        return data

+    @query_params()
+    def pending_tasks(self, params=None):
+        """
+        The pending cluster tasks API returns a list of any cluster-level
+        changes (e.g. create index, update mapping, allocate or fail shard)
+        which have not yet been executed.
+        `<http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/cluster-pending.html>`_
+        """
+        _, data = self.transport.perform_request('GET', '/_cluster/pending_tasks',
+            params=params)
+        return data
+
    @query_params('filter_blocks', 'filter_index_templates', 'filter_indices',
        'filter_metadata', 'filter_nodes', 'filter_routing_table', 'local',
        'master_timeout', 'flat_settings')