tasks/ceph_manager: make utility_task cluster-aware

Signed-off-by: Josh Durgin <jdurgin@redhat.com>
(cherry picked from commit 274d79ade39bddfcc13d3b9cb6829bac8b693c1f)

diff --git a/tasks/ceph_manager.py b/tasks/ceph_manager.py
index 02e7f7d20f7ce498b4b6cd7d99efd9a748a19a32..82a2ffaa3d9521a7b287b1baa3f90271439b92f7 100644 (file)
--- a/tasks/ceph_manager.py
+++ b/tasks/ceph_manager.py
@@ -1973,7 +1973,8 @@ def utility_task(name):
             config = {}
         args = config.get('args', [])
         kwargs = config.get('kwargs', {})
-        fn = getattr(ctx.manager, name)
+        cluster = config.get('cluster', 'ceph')
+        fn = getattr(ctx.managers[cluster], name)
         fn(*args, **kwargs)
     return task