Просмотр исходного кода

Do not sanitize action info before saving to DB.

Nashwan Azhari 6 лет назад
Родитель
Сommit
acd546d0d1
2 измененных файлов с 4 добавлено и 4 удалено
  1. 1 3
      coriolis/conductor/rpc/server.py
  2. 3 1
      coriolis/tasks/replica_tasks.py

+ 1 - 3
coriolis/conductor/rpc/server.py

@@ -1960,9 +1960,7 @@ class ConductorServerEndpoint(object):
                             task_result)})
                 updated_task_info = (
                     db_api.update_transfer_action_info_for_instance(
-                        ctxt, action_id, task.instance,
-                        utils.sanitize_task_info(
-                            task_result)))
+                        ctxt, action_id, task.instance, task_result))
             else:
                 action = db_api.get_action(ctxt, action_id)
                 updated_task_info = action.info[task.instance]

+ 3 - 1
coriolis/tasks/replica_tasks.py

@@ -243,7 +243,9 @@ class DeleteReplicaDisksTask(base.TaskRunner):
         if volumes_info:
             LOG.warn(
                 "'volumes_info' should have been void after disk "
-                "deletion task but it is: %s" % volumes_info)
+                "deletion task but it is: %s" % (
+                    utils.sanitize_task_info({
+                        'volumes_info': volumes_info})))
         elif volumes_info is None:
             volumes_info = []