fix: reset threading lock at conftest

Avaiga · Mar 1, 2024 · 613d049 · 613d049
1 parent 9fcb5eb
commit 613d049
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/tests/core/conftest.py b/tests/core/conftest.py
@@ -14,6 +14,7 @@
 import shutil
 from datetime import datetime
 from queue import Queue
+from threading import Lock
 from unittest.mock import patch
 
 import pandas as pd
@@ -378,6 +379,7 @@ def _init_orchestrator():
         _OrchestratorFactory._build_dispatcher(force_restart=True)
         _OrchestratorFactory._orchestrator.jobs_to_run = Queue()
         _OrchestratorFactory._orchestrator.blocked_jobs = []
+        _OrchestratorFactory._orchestrator.lock = Lock()
 
     return _init_orchestrator