tasks/ceph_manager: make utility_task cluster-aware

Signed-off-by: Josh Durgin <jdurgin@redhat.com>

diff --git a/tasks/ceph_manager.py b/tasks/ceph_manager.py
index 71578645afe5e756b59ce615caa4bc05809d4afe..ad13801782a4ba9761abddbc2f127ef83053582b 100644 (file)
--- a/tasks/ceph_manager.py
+++ b/tasks/ceph_manager.py
@@ -2061,7 +2061,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