diff --git a/mistral/services/action_heartbeat_checker.py b/mistral/services/action_heartbeat_checker.py index 80e3f3a65..b44dd121f 100644 --- a/mistral/services/action_heartbeat_checker.py +++ b/mistral/services/action_heartbeat_checker.py @@ -13,7 +13,7 @@ # limitations under the License. import datetime -import eventlet +import threading import time from mistral import context as auth_ctx @@ -137,7 +137,7 @@ def start(): _stopped = False - eventlet.spawn_after(wait_time, _loop) + threading.Timer(wait_time, _loop).start() def stop(graceful=False): diff --git a/mistral/services/action_heartbeat_sender.py b/mistral/services/action_heartbeat_sender.py index 62e765e9e..694c3d915 100644 --- a/mistral/services/action_heartbeat_sender.py +++ b/mistral/services/action_heartbeat_sender.py @@ -12,7 +12,7 @@ # See the License for the specific language governing permissions and # limitations under the License. -import eventlet +import threading import time from oslo_config import cfg @@ -101,7 +101,7 @@ def start(): _stopped = False - eventlet.spawn(_loop) + threading.Thread(target=_loop).start() def stop(graceful=False):