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

Make task-related worker-conductor interactions synchronous.

This prevents possible desync problems when it comes to operations like
confirming task running or process setting.
Nashwan Azhari 5 лет назад
Родитель
Сommit
d173e9f5c7
1 измененных файлов с 5 добавлено и 5 удалено
  1. 5 5
      coriolis/conductor/rpc/client.py

+ 5 - 5
coriolis/conductor/rpc/client.py

@@ -259,24 +259,24 @@ class ConductorClient(rpc.BaseRPCClient):
             ctxt, 'cancel_migration', migration_id=migration_id, force=force)
 
     def set_task_host(self, ctxt, task_id, host):
-        self._cast(
+        self._call(
             ctxt, 'set_task_host', task_id=task_id, host=host)
 
     def set_task_process(self, ctxt, task_id, process_id):
-        self._cast(
+        self._call(
             ctxt, 'set_task_process', task_id=task_id, process_id=process_id)
 
     def task_completed(self, ctxt, task_id, task_result):
-        self._cast(
+        self._call(
             ctxt, 'task_completed', task_id=task_id, task_result=task_result)
 
     def confirm_task_cancellation(self, ctxt, task_id, cancellation_details):
-        self._cast(
+        self._call(
             ctxt, 'confirm_task_cancellation', task_id=task_id,
             cancellation_details=cancellation_details)
 
     def set_task_error(self, ctxt, task_id, exception_details):
-        self._cast(
+        self._call(
             ctxt, 'set_task_error', task_id=task_id,
             exception_details=exception_details)