add flag to know when guardian is setup

Signed-off-by: Sylvain Hellegouarch <[email protected]>

Author: Lawouach

CHANGELOG.md

@@ -2,7 +2,15 @@
 
 ## [Unreleased][]
 
-[Unreleased]: https://github.com/chaostoolkit/chaostoolkit-addons/compare/0.6.0...HEAD
+[Unreleased]: https://github.com/chaostoolkit/chaostoolkit-addons/compare/0.7.0...HEAD
+
+## [0.7.0][]
+
+[0.7.0]: https://github.com/chaostoolkit/chaostoolkit-addons/compare/0.6.0...0.7.0
+
+### Changed
+
+- Added a flag to know when the guardian was fully setup
 
 ## [0.6.0][]
 

chaosaddons/controls/safeguards.py

@@ -110,6 +110,7 @@ class Guardian:
     def __init__(self) -> None:
         self._lock = threading.Lock()
         self._interrupted = False
+        self._setup = False
 
     @property
     def interrupted(self) -> bool:
@@ -148,6 +149,7 @@ def prepare(self, probes: List[Probe]) -> None:
         self.now = ThreadPoolExecutor(max_workers=now_count or 1)
         self.once = ThreadPoolExecutor(max_workers=once_count or 1)
         self.repeating = ThreadPoolExecutor(max_workers=repeating_count or 1)
+        self._setup = True
 
     def run(self, experiment: Experiment, probes: List[Probe],
             configuration: Configuration, secrets: Secrets,
@@ -201,6 +203,9 @@ def terminate(self) -> None:
         """
         Stop the guardian and all its safeguards.
         """
+        if not self._setup:
+            return None
+
         self.repeating_until.set()
         self.now.shutdown(wait=True)
         self.repeating.shutdown(wait=True)

setup.py

@@ -5,5 +5,5 @@
     setup(
         use_scm_version=True,
         name="chaostoolkit-addons",
-        version="0.6.0",
+        version="0.7.0",
     )