X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=a1%2Fdata.py;h=cd44962bd574c48643e400dd6caceda63a4b0dad;hb=20d87ede528b9c509fe1b0c51c6383b8d307c2c8;hp=ca0acb37fb1c3a46c31053aa072cc54c0072160b;hpb=fe30c1726c397b1ee100cd3d3795758e7d21b6bf;p=ric-plt%2Fa1.git diff --git a/a1/data.py b/a1/data.py index ca0acb3..cd44962 100644 --- a/a1/data.py +++ b/a1/data.py @@ -17,6 +17,7 @@ """ Represents A1s database and database access functions. """ +import distutils.util import os import time from threading import Thread @@ -27,6 +28,7 @@ from a1.exceptions import PolicyTypeNotFound, PolicyInstanceNotFound, PolicyType # constants INSTANCE_DELETE_NO_RESP_TTL = int(os.environ.get("INSTANCE_DELETE_NO_RESP_TTL", 5)) INSTANCE_DELETE_RESP_TTL = int(os.environ.get("INSTANCE_DELETE_RESP_TTL", 5)) +USE_FAKE_SDL = bool(distutils.util.strtobool(os.environ.get("USE_FAKE_SDL", "False"))) A1NS = "A1m_ns" TYPE_PREFIX = "a1.policy_type." INSTANCE_PREFIX = "a1.policy_instance." @@ -35,7 +37,9 @@ HANDLER_PREFIX = "a1.policy_handler." mdc_logger = Logger(name=__name__) -SDL = SDLWrapper() +if USE_FAKE_SDL: + mdc_logger.debug("Using fake SDL") +SDL = SDLWrapper(use_fake_sdl=USE_FAKE_SDL) # Internal helpers