From 90efeb281ee1f78f6ac1d83b659397f4ec82c1c6 Mon Sep 17 00:00:00 2001
From: Derek Horton <dehort@redhat.com>
Date: Fri, 5 Aug 2022 15:02:37 -0500
Subject: [PATCH] Use thread.join(timeout) to avoid busy waiting and simplify
 interval event posting logic

Resolves: rhbz#2104199

(cherry picked from commit 478930cca7a8d4acf21aef0715e42052315cb24e)
---
 rhc_worker_playbook/server.py | 12 +++---------
 1 file changed, 3 insertions(+), 9 deletions(-)

diff --git a/rhc_worker_playbook/server.py b/rhc_worker_playbook/server.py
index 8e9826f..e41482d 100644
--- a/rhc_worker_playbook/server.py
+++ b/rhc_worker_playbook/server.py
@@ -231,20 +231,14 @@ class WorkerService(yggdrasil_pb2_grpc.WorkerServicer):
             artifact_dir=RUNNER_ARTIFACTS_DIR,
             rotate_artifacts=RUNNER_ROTATE_ARTIFACTS)
 
-        # initialize elapsed counter
-        elapsedTime = 0
-        startTime = time.time()
+        # wait for the thread to finish
         while runnerThread.is_alive():
-            time.sleep(1)
-            elapsedTime = time.time() - startTime
-            if elapsedTime >= response_interval:
+            runnerThread.join(response_interval)
+            if runnerThread.is_alive():
                 # hit the interval, post events
                 _log("Hit the response interval. Posting current status...")
                 returnedEvents = _composeDispatcherMessage(events, return_url, response_to)
                 response = self.dispatcher.Send(returnedEvents)
-                # reset interval timer
-                elapsedTime = 0
-                startTime = time.time()
 
         if runner.status == 'failed':
             # last event sould be the failure, find the reason