Code Review
/
ric-plt
/
a1.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Align unit and int tests w.r.t. AC xapp
[ric-plt/a1.git]
/
a1
/
controller.py
diff --git
a/a1/controller.py
b/a1/controller.py
index
6f21830
..
1022320
100644
(file)
--- a/
a1/controller.py
+++ b/
a1/controller.py
@@
-22,11
+22,11
@@
from flask import Response
from jsonschema import validate
from jsonschema.exceptions import ValidationError
import connexion
from jsonschema import validate
from jsonschema.exceptions import ValidationError
import connexion
-from
a1 import get_module_l
ogger
+from
mdclogpy import L
ogger
from a1 import a1rmr, exceptions, data
from a1 import a1rmr, exceptions, data
-
logger = get_module_logger(
__name__)
+
mdc_logger = Logger(name=
__name__)
def _try_func_return(func):
def _try_func_return(func):
@@
-41,7
+41,7
@@
def _try_func_return(func):
return "", 404
except BaseException as exc:
# catch all, should never happen...
return "", 404
except BaseException as exc:
# catch all, should never happen...
- logger.exception(exc)
+
mdc_
logger.exception(exc)
return Response(status=500)
return Response(status=500)
@@
-166,7
+166,7
@@
def create_or_replace_policy_instance(policy_type_id, policy_instance_id):
# send rmr (best effort)
body = _gen_body_to_handler("CREATE", policy_type_id, policy_instance_id, payload=instance)
# send rmr (best effort)
body = _gen_body_to_handler("CREATE", policy_type_id, policy_instance_id, payload=instance)
- a1rmr.queue_work({"payload": json.dumps(body), "
msg type
": policy_type_id})
+ a1rmr.queue_work({"payload": json.dumps(body), "
ptid
": policy_type_id})
return "", 202
return "", 202
@@
-187,7
+187,7
@@
def delete_policy_instance(policy_type_id, policy_instance_id):
# send rmr (best effort)
body = _gen_body_to_handler("DELETE", policy_type_id, policy_instance_id)
# send rmr (best effort)
body = _gen_body_to_handler("DELETE", policy_type_id, policy_instance_id)
- a1rmr.queue_work({"payload": json.dumps(body), "
msg type
": policy_type_id})
+ a1rmr.queue_work({"payload": json.dumps(body), "
ptid
": policy_type_id})
return "", 202
return "", 202