join threads on tests

Author: DvirDukhan

tests/flow/tests_dag.py

@@ -771,6 +771,7 @@ def run():
             # assert that result tensor exists
             ret = con.execute_command("EXISTS {}".format(result_tensor_keyname))
             env.assertEqual(ret, 1)
+            t.join()
 
 
 def test_dag_with_timeout(env):

tests/flow/tests_onnx.py

@@ -229,6 +229,7 @@ def run():
     argmax = max(range(len(values)), key=lambda i: values[i])
 
     env.assertEqual(argmax, 1)
+    t.join()
 
 
 def test_onnx_modelrun_iris(env):

tests/flow/tests_pytorch.py

@@ -284,6 +284,7 @@ def run():
         exception = e
         env.assertEqual(type(exception), redis.exceptions.ResponseError)
         env.assertEqual("Model did not generate the expected batch size", exception.__str__())
+    t.join()