[bumpversion]
-current_version = 2.1.8
+current_version = 2.1.9
commit = False
tag = False
FROM python:3.8-alpine
# copy rmr libraries from builder image in lieu of an Alpine package
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/lib64/librmr* /usr/local/lib64/
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/lib64/librmr* /usr/local/lib64/
# copy python modules; this makes the 2 stage python build work
COPY --from=compile-image /home/a1user/.local /home/a1user/.local
RUN pip install --upgrade pip && pip install tox gevent
# copy rmr libraries from builder image in lieu of an Alpine package
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/lib64/librmr* /usr/local/lib64/
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/lib64/librmr* /usr/local/lib64/
# copies
COPY setup.py tox.ini /tmp/
mdc_logger = Logger(name=__name__)
+# With Nanomsg and NNG it was possible for a send attempt to have a "soft"
+# failure which did warrant some retries if the status of the send is RMR_ERR_RETRY.
+# Because of the way NNG worked, it sometimes required many tens of retries,
+# and a retry state happened often for even moderately "verbose" applications.
+# With SI95 there is still a possibility that a retry is necessary, but it is very rare.
RETRY_TIMES = int(os.environ.get("A1_RMR_RETRY_TIMES", 4))
A1_POLICY_REQUEST = 20010
A1_POLICY_RESPONSE = 20011
self.mrc = init_func_override()
else:
mdc_logger.debug("Waiting for rmr to initialize..")
- # rmr.RMRFL_MTCALL puts RMR into a multithreaded mode, where a receiving thread populates an
- # internal ring of messages, and receive calls read from that
+ # rmr.RMRFL_MTCALL puts RMR into a multithreaded mode, where a receiving thread
+ # populates an internal ring of messages, and receive calls read from that.
# currently the size is 2048 messages, so this is fine for the foreseeable future
self.mrc = rmr.rmr_init(b"4562", rmr.RMR_MAX_RCV_BYTES, rmr.RMRFL_MTCALL)
while rmr.rmr_ready(self.mrc) == 0:
def _assert_good_send(self, sbuf, pre_send_summary):
"""
- common helper function for _send_msg and _rts_msg
+ Extracts the send result and logs a detailed warning if the send failed.
+ Returns the message state, an integer that indicates the result.
"""
post_send_summary = rmr.message_summary(sbuf)
- if post_send_summary["message state"] == 0 and post_send_summary["message status"] == "RMR_OK":
- return True
- mdc_logger.debug("Message NOT sent!")
- mdc_logger.debug("Pre-send summary: {0}, Post-send summary: {1}".format(pre_send_summary, post_send_summary))
- return False
+ if post_send_summary[rmr.RMR_MS_MSG_STATE] != rmr.RMR_OK:
+ mdc_logger.warning("RMR send failed; pre-send summary: {0}, post-send summary: {1}".format(pre_send_summary, post_send_summary))
+ return post_send_summary[rmr.RMR_MS_MSG_STATE]
def _send_msg(self, pay, mtype, subid):
"""
- sends a msg
+ Creates and sends a message via RMR's send-message feature with the specified payload
+ using the specified message type and subscription ID.
"""
+ sbuf = rmr.rmr_alloc_msg(self.mrc, len(pay), payload=pay, gen_transaction_id=True, mtype=mtype, sub_id=subid)
+ sbuf.contents.sub_id = subid
+ pre_send_summary = rmr.message_summary(sbuf)
for _ in range(0, RETRY_TIMES):
- sbuf = rmr.rmr_alloc_msg(self.mrc, len(pay), payload=pay, gen_transaction_id=True, mtype=mtype, sub_id=subid)
- sbuf.contents.sub_id = subid
- pre_send_summary = rmr.message_summary(sbuf)
- mdc_logger.debug("Trying to send message: {}".format(pre_send_summary))
- sbuf = rmr.rmr_send_msg(self.mrc, sbuf) # send
- if self._assert_good_send(sbuf, pre_send_summary):
- rmr.rmr_free_msg(sbuf) # free
- return
+ mdc_logger.debug("_send_msg: sending: {}".format(pre_send_summary))
+ sbuf = rmr.rmr_send_msg(self.mrc, sbuf)
+ msg_state = self._assert_good_send(sbuf, pre_send_summary)
+ if msg_state != rmr.RMR_ERR_RETRY:
+ break
- mdc_logger.debug("A1 did NOT send the message successfully after {} retries!".format(RETRY_TIMES))
+ rmr.rmr_free_msg(sbuf)
+ if msg_state != rmr.RMR_OK:
+ mdc_logger.warning("_send_msg: failed after {} retries".format(RETRY_TIMES))
def _rts_msg(self, pay, sbuf_rts, mtype):
"""
- sends a message using rts
- we do not call free here because we may rts many times; it is called after the rts loop
+ Sends a message via RMR's return-to-sender feature.
+ This neither allocates nor frees a message buffer because we may rts many times.
+ Returns the message buffer from the RTS function, which may reallocate it.
"""
+ pre_send_summary = rmr.message_summary(sbuf_rts)
for _ in range(0, RETRY_TIMES):
- pre_send_summary = rmr.message_summary(sbuf_rts)
+ mdc_logger.debug("_rts_msg: sending: {}".format(pre_send_summary))
sbuf_rts = rmr.rmr_rts_msg(self.mrc, sbuf_rts, payload=pay, mtype=mtype)
- if self._assert_good_send(sbuf_rts, pre_send_summary):
+ msg_state = self._assert_good_send(sbuf_rts, pre_send_summary)
+ if msg_state != rmr.RMR_ERR_RETRY:
break
+
+ if msg_state != rmr.RMR_OK:
+ mdc_logger.warning("_rts_msg: failed after {} retries".format(RETRY_TIMES))
return sbuf_rts # in some cases rts may return a new sbuf
def _handle_sends(self):
for (msg, sbuf) in self.rcv_func():
# TODO: in the future we may also have to catch SDL errors
try:
- mtype = msg["message type"]
+ mtype = msg[rmr.RMR_MS_MSG_TYPE]
except (KeyError, TypeError, json.decoder.JSONDecodeError):
- mdc_logger.debug("Dropping malformed policy ack/query message: {0}".format(msg))
+ mdc_logger.warning("Dropping malformed message: {0}".format(msg))
if mtype == A1_POLICY_RESPONSE:
try:
# got a policy response, update status
- pay = json.loads(msg["payload"])
+ pay = json.loads(msg[rmr.RMR_MS_PAYLOAD])
data.set_policy_instance_status(
pay["policy_type_id"], pay["policy_instance_id"], pay["handler_id"], pay["status"]
)
mdc_logger.debug("Successfully received status update: {0}".format(pay))
except (PolicyTypeNotFound, PolicyInstanceNotFound):
- mdc_logger.debug("Received a response for a non-existent instance")
+ mdc_logger.warning("Received a response for a non-existent type/instance: {0}".format(msg))
except (KeyError, TypeError, json.decoder.JSONDecodeError):
- mdc_logger.debug("Dropping malformed policy ack message: {0}".format(msg))
+ mdc_logger.warning("Dropping malformed policy response: {0}".format(msg))
elif mtype == A1_POLICY_QUERY:
try:
# got a query, do a lookup and send out all instances
- pti = json.loads(msg["payload"])["policy_type_id"]
+ pti = json.loads(msg[rmr.RMR_MS_PAYLOAD])["policy_type_id"]
instance_list = data.get_instance_list(pti) # will raise if a bad type
- mdc_logger.debug("Received a query for a good type: {0}".format(msg))
+ mdc_logger.debug("Received a query for a known policy type: {0}".format(msg))
for pii in instance_list:
instance = data.get_policy_instance(pti, pii)
payload = json.dumps(messages.a1_to_handler("CREATE", pti, pii, instance)).encode("utf-8")
sbuf = self._rts_msg(payload, sbuf, A1_POLICY_REQUEST)
except (PolicyTypeNotFound):
- mdc_logger.debug("Received a query for a non-existent type: {0}".format(msg))
+ mdc_logger.warning("Received a policy query for a non-existent type: {0}".format(msg))
except (KeyError, TypeError, json.decoder.JSONDecodeError):
- mdc_logger.debug("Dropping malformed policy query message: {0}".format(msg))
+ mdc_logger.warning("Dropping malformed policy query: {0}".format(msg))
else:
- mdc_logger.debug("Received message type {0} but A1 does not handle this".format(mtype))
+ mdc_logger.warning("Received message type {0} but A1 does not handle this".format(mtype))
# we must free each sbuf
rmr.rmr_free_msg(sbuf)
2. if a1 has received at least one status and at least one is OK, we return "IN EFFECT"
3. "NOT IN EFFECT" otherwise (no statuses, or none are OK but not all are deleted)
"""
-
return _try_func_return(lambda: data.get_policy_instance_status(policy_type_id, policy_instance_id))
# The Jenkins job uses this string for the tag in the image name
# for example nexus3.o-ran-sc.org:10004/my-image-name:my-tag
---
-tag: 2.1.8
+tag: 2.1.9
:depth: 3
:local:
+
+[2.1.9] - 2020-05-26
+--------------------
+
+* Fix _send_msg method to free allocated RMR message buffers
+* Adjust send-message methods to retry only on RMR_ERR_RETRY
+* Use constants from ricxappframe.rmr instead of hardcoded strings
+* Upgrade RMR to version 4.0.5
+* Upgrade tavern to version 1.2.2
+
+
[2.1.8] - 2020-04-30
--------------------
[2.1.6] - 4/7/2020
-------------------
-::
- * Switch to rmr 3.6.3
- * Switch to using rmr in the ricxappframe
+* Switch to rmr 3.6.3
+* Switch to using rmr in the ricxappframe
[2.1.5] - 3/19/2020
-------------------
-::
- * Switch to python3.8
- * Switch to SI95 from NNG (rmr v3 vs rmr v1)
- * The switch to SI95 led to a rabbit hole in which we eventually discovered that rmr_send may sometimes block for an arbitrary period of time. Because of this issue, a1's sends are now threaded. Please see the longer comment about this in a1rmr.
- * Bump version of py xapp frame (SDL used only) in A1
- * Bump version of go xapp frame (0.0.24 -> 0.4.2) in integration tests
- * Add some additional logging in A1
+* Switch to python3.8
+* Switch to SI95 from NNG (rmr v3 vs rmr v1)
+* The switch to SI95 led to a rabbit hole in which we eventually discovered that rmr_send may sometimes block for an arbitrary period of time. Because of this issue, a1's sends are now threaded. Please see the longer comment about this in a1rmr.
+* Bump version of py xapp frame (SDL used only) in A1
+* Bump version of go xapp frame (0.0.24 -> 0.4.2) in integration tests
+* Add some additional logging in A1
[2.1.4] - 3/6/2020
-------------------
-::
- * SDL Wrapper was moved into the python xapp framework; use it from there instead.
+* SDL Wrapper was moved into the python xapp framework; use it from there instead.
[2.1.3] - 2/13/2020
-------------------
-::
- * This is a pretty big amount of work/changes, however no APIs were changed hence the semver patch
- * Switches A1's three test receivers (integration tests) over to golang; this was mostly done to learn the go xapp framework and they are identical in functionality.
- * Upgrades the version of rmr in A1 and all integration receivers to 1.13.*
- * Uses a much fancier Docker build to reduce the size of a1's image. The python:3.7-alpine image itself is 98MB and A1 is now only ~116MB, so we're done optimizing A1's container size.
+* This is a pretty big amount of work/changes, however no APIs were changed hence the semver patch
+* Switches A1's three test receivers (integration tests) over to golang; this was mostly done to learn the go xapp framework and they are identical in functionality.
+* Upgrades the version of rmr in A1 and all integration receivers to 1.13.*
+* Uses a much fancier Docker build to reduce the size of a1's image. The python:3.7-alpine image itself is 98MB and A1 is now only ~116MB, so we're done optimizing A1's container size.
[2.1.2] - 1/22/2020
-------------------
-::
-
- * Upgrades from sdl 2.0.2 to 2.0.3
- * Integrates an sdl healthcheck into a1's healthcheck
+* Upgrades from sdl 2.0.2 to 2.0.3
+* Integrates an sdl healthcheck into a1's healthcheck
[2.1.1] - 1/14/2020
-------------------
-::
+* Upgrades from sdl 1.0.0 to 2.0.2
+* Delete a1test_helpers because SDL 2.0.2 provides the mockup we need
+* Remove general catch all from A1
- * Upgrades from sdl 1.0.0 to 2.0.2
- * Delete a1test_helpers because SDL 2.0.2 provides the mockup we need
- * Remove general catch all from A1
[2.1.0] - 1/8/2020
------------------
-::
+* Represents a resillent version of 2.0.0 that uses Redis for persistence
+* Now relies on SDL and dbaas; SDL is the python interface library to dbaas
+* Adds a 503 http code to nearly all http methods, as A1 now depends on an upstream system
+* Integration tests have a copy of a dbaas helm chart, however the goal is to simplify that deployment per https://jira.o-ran-sc.org/browse/RIC-45
+* Unit tests have a mockup of SDL, however again the goal is to simplify as SDL grows per https://jira.o-ran-sc.org/browse/RIC-44
- * Represents a resillent version of 2.0.0 that uses Redis for persistence
- * Now relies on SDL and dbaas; SDL is the python interface library to dbaas
- * Adds a 503 http code to nearly all http methods, as A1 now depends on an upstream system
- * Integration tests have a copy of a dbaas helm chart, however the goal is to simplify that deployment per https://jira.o-ran-sc.org/browse/RIC-45
- * Unit tests have a mockup of SDL, however again the goal is to simplify as SDL grows per https://jira.o-ran-sc.org/browse/RIC-44
[2.0.0] - 12/9/2019
-------------------
-::
+* Implements new logic around when instances are deleted. See flowcharts in docs/. Basically timeouts now trigger to actually delete instances from a1s database, and these timeouts are configurable.
+* Eliminates the barrier to deleting an instance when no xapp evdr replied (via timeouts)
+* Add two new ENV variables that control timeouts
+* Make unit tests more modular so new workflows can be tested easily
+* Fixes the API for ../status to return a richer structure. This is an (albeit tiny) API change.
+* Clean up unused items in the integration tests helm chart
+* Removed "RMR_RCV_RETRY_INTERVAL" leftovers since this isn't used anymore
+* Uses the standard RIC logging library
+* Switch the backend routing scheme to using subscription id with constant message types, per request.
+* Given the above, policy type ids can be any valid 32bit greater than 0
+* Decouple the API between northbound and A1 from A1 with xapps. This is now two seperate OpenAPI files
+* Update example for AC Xapp
+* Updgrade rmr and rmr-python to utilize new features; lots of cleanups because of that
+* Implements a POLICY QUERY feature where A1 listens for queries for a policy type. A1 then responds via multiple RTS messages every policy instance of that policy type (and expects an ACK back from xapps as usual). This feature can be used for xapp recovery etc.
- * Implements new logic around when instances are deleted. See flowcharts in docs/. Basically timeouts now trigger to actually delete instances from a1s database, and these timeouts are configurable.
- * Eliminates the barrier to deleting an instance when no xapp evdr replied (via timeouts)
- * Add two new ENV variables that control timeouts
- * Make unit tests more modular so new workflows can be tested easily
- * Fixes the API for ../status to return a richer structure. This is an (albeit tiny) API change.
- * Clean up unused items in the integration tests helm chart
- * Removed "RMR_RCV_RETRY_INTERVAL" leftovers since this isn't used anymore
- * Uses the standard RIC logging library
- * Switch the backend routing scheme to using subscription id with constant message types, per request.
- * Given the above, policy type ids can be any valid 32bit greater than 0
- * Decouple the API between northbound and A1 from A1 with xapps. This is now two seperate OpenAPI files
- * Update example for AC Xapp
- * Updgrade rmr and rmr-python to utilize new features; lots of cleanups because of that
- * Implements a POLICY QUERY feature where A1 listens for queries for a policy type. A1 then responds via multiple RTS messages every policy instance of that policy type (and expects an ACK back from xapps as usual). This feature can be used for xapp recovery etc.
[1.0.4]
-------
-::
+* Only external change here is to healthcheck the rmr thread as part of a1s healthcheck. k8s will now respin a1 if that is failing.
+* Refactors (simplifies) how we wait for rmr initialization; it is now called as part of __init__
+* Refactors (simplifies) how the thread is actually launched; it is now internal to the object and also a part of __init__
+* Cleans up unit testing; a1rmr now exposes a replace_rcv_func; useful for unit testing, harmless if not called otherwise
+* Upgrades to rmr-python 1.0.0 for simpler message allocation
- * Only external change here is to healthcheck the rmr thread as part of a1s healthcheck. k8s will now respin a1 if that is failing.
- * Refactors (simplifies) how we wait for rmr initialization; it is now called as part of __init__
- * Refactors (simplifies) how the thread is actually launched; it is now internal to the object and also a part of __init__
- * Cleans up unit testing; a1rmr now exposes a replace_rcv_func; useful for unit testing, harmless if not called otherwise
- * Upgrades to rmr-python 1.0.0 for simpler message allocation
[1.0.3] - 10/22/2019
--------------------
-::
+* Move database cleanup (e.g., deleting instances based on statuses) into the polling loop
+* Rework how unit testing works with the polling loop; prior, exceptions were being thrown silently from the thread but not printed. The polling thread has now been paramaterized with override functions for the purposes of testing
+* Make type cleanup more efficient since we know exactly what instances were touched, and it's inefficient to iterate over all instances if they were not
+* Bump rmr-python version, and bump rmr version
+* Still an item left to do in this work; refactor the thread slightly to tie in a healthcheck with a1s healthcheck. We need k8s to restart a1 if that thread dies too.
- * Move database cleanup (e.g., deleting instances based on statuses) into the polling loop
- * Rework how unit testing works with the polling loop; prior, exceptions were being thrown silently from the thread but not printed. The polling thread has now been paramaterized with override functions for the purposes of testing
- * Make type cleanup more efficient since we know exactly what instances were touched, and it's inefficient to iterate over all instances if they were not
- * Bump rmr-python version, and bump rmr version
- * Still an item left to do in this work; refactor the thread slightly to tie in a healthcheck with a1s healthcheck. We need k8s to restart a1 if that thread dies too.
[1.0.2] - 10/17/2019
--------------------
-::
+* a1 now has a seperate, continuous polling thread, which will enable operations like database cleanup
+ (based on ACKs) and external notifications in real time, rather than when the API is invoked
+* all rmr send and receive operations are now in this thread
+* introduces a thread safe job queue between the two threads
+* Not done yet: database cleanups in the thread
+* Bump rmr python version
+* Clean up some logging
- * a1 now has a seperate, continuous polling thread
- this will enable operations like database cleanup (based on ACKs) and external notifications in real time,
- rather than when the API is invoked
- * all rmr send and receive operations are now in this thread
- * introduces a thread safe job queue between the two threads
- * Not done yet: database cleanups in the thread
- * Bump rmr python version
- * Clean up some logging
[1.0.1] - 10/15/2019
--------------------
-::
-
- * Moves the "database" access calls to mimick the SDL API, in preparation for moving to SDL
- * Does not yet actually use SDL or Redis, but the transition to those will be much shorter after this change.
+* Moves the "database" access calls to mimick the SDL API, in preparation for moving to SDL
+* Does not yet actually use SDL or Redis, but the transition to those will be much shorter after this change.
[1.0.0] - 10/7/2019
-------------------
-::
-
- * Represents v1.0.0 of the A1 API for O-RAN-SC Release A
- * Finished here:
- - Implement type DELETE
- - Clean up where policy instance cleanups happen
+* Represents v1.0.0 of the A1 API for O-RAN-SC Release A
+* Finished here:
+ - Implement type DELETE
+ - Clean up where policy instance cleanups happen
[0.14.1] - 10/2/2019
apiVersion: v1
description: A1 Helm chart for Kubernetes
name: a1mediator
-version: 2.1.8
+version: 2.1.9
#!/bin/sh
-git clone --branch 4.0.2 https://gerrit.oran-osc.org/r/ric-plt/lib/rmr \
+git clone --branch 4.0.5 https://gerrit.oran-osc.org/r/ric-plt/lib/rmr \
&& cd rmr \
&& mkdir .build; cd .build \
&& echo "<<<installing rmr devel headers>>>" \
FROM nexus3.o-ran-sc.org:10004/o-ran-sc/bldr-alpine3:12-a3.11
# copy rmr headers and libraries from builder image in lieu of an Alpine package
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/include/rmr /usr/local/include/rmr
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/lib64/librmr* /usr/local/lib64/
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/include/rmr /usr/local/include/rmr
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/lib64/librmr* /usr/local/lib64/
# go will complain if there is a go.mod at the root of the GOPATH so we can't.
RUN mkdir myxapp
FROM alpine:3.11
# copy rmr libraries from builder image in lieu of an Alpine package
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/lib64/librmr* /usr/local/lib64/
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/lib64/librmr* /usr/local/lib64/
COPY --from=0 /myxapp/receiver .
COPY delay-config-file.yaml .
FROM nexus3.o-ran-sc.org:10004/o-ran-sc/bldr-alpine3:12-a3.11
# copy rmr headers and libraries from builder image in lieu of an Alpine package
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/include/rmr /usr/local/include/rmr
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/lib64/librmr* /usr/local/lib64/
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/include/rmr /usr/local/include/rmr
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/lib64/librmr* /usr/local/lib64/
# go will complain if there is a go.mod at the root of the GOPATH so we can't.
RUN mkdir myxapp
FROM alpine:3.11
# copy rmr libraries from builder image in lieu of an Alpine package
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/lib64/librmr* /usr/local/lib64/
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/lib64/librmr* /usr/local/lib64/
COPY --from=0 /myxapp/receiver .
COPY query-config-file.yaml .
FROM nexus3.o-ran-sc.org:10004/o-ran-sc/bldr-alpine3:12-a3.11
# copy rmr headers and libraries from builder image in lieu of an Alpine package
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/include/rmr /usr/local/include/rmr
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/lib64/librmr* /usr/local/lib64/
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/include/rmr /usr/local/include/rmr
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/lib64/librmr* /usr/local/lib64/
# go will complain if there is a go.mod at the root of the GOPATH so we can't.
RUN mkdir myxapp
FROM alpine:3.11
# copy rmr libraries from builder image in lieu of an Alpine package
-COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.2 /usr/local/lib64/librmr* /usr/local/lib64/
+COPY --from=nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-alpine3-rmr:4.0.5 /usr/local/lib64/librmr* /usr/local/lib64/
COPY --from=0 /myxapp/receiver .
COPY test-config-file.yaml .
# CI script installs RMR from PackageCloud using this version
---
-version: 4.0.2
+version: 4.0.5
setup(
name="a1",
- version="2.1.8",
+ version="2.1.9",
packages=find_packages(exclude=["tests.*", "tests"]),
author="Tommy Carpenter",
description="RIC A1 Mediator for policy/intent changes",
getlogs.sh
passenv = *
deps =
- tavern == 1.0.0 # pin the version
+ tavern == 1.2.2 # pin the version
changedir=integration_tests
commands_pre=
echo "WARNING: make sure you are running with latest docker builds!"
helm install --devel dbaas dbaas-service
kubectl get pods --namespace=default
echo "delay so pods can start"
- sleep 30
+ sleep 60
kubectl get pods --namespace=default
echo "forward ports"
./portforward.sh
Code Review / ric-plt / a1.git / commitdiff