debug

Author: cognifloyd

st2common/st2common/policies/concurrency.py

@@ -14,6 +14,11 @@
 # limitations under the License.
 
 from __future__ import absolute_import
+
+import os
+
+from oslo_config import cfg
+
 from st2common.constants import action as action_constants
 from st2common.policies import base
 from st2common.services import coordination
@@ -30,6 +35,7 @@ def __init__(self, policy_ref, policy_type, threshold=0, action="delay"):
         self.policy_action = action
 
         self.coordinator = coordination.get_coordinator(start_heart=True)
+        raise ValueError(f"ST2TESTS_REDIS_HOST={os.environ.get('ST2TESTS_REDIS_HOST')} url={cfg.CONF.coordination.url} coordinator={self.coordinator}")
 
     def _get_status_for_policy_action(self, action):
         if action == "delay":