AtHeartEngineer/SIMoN
1
0
Fork 0
mirror of https://github.com/JHUAPL/SIMoN.git synced 2026-01-09 14:57:56 -05:00
Code Issues Packages Projects Releases Wiki Activity

better logging level for info

Browse Source 
Former-commit-id: ff4922ff3cc7af3b974f571e15da367a74a0676f
This commit is contained in:
Michael T. Kelbaugh
2020-02-27 10:50:53 -05:00
parent 58ebb0b04e
commit 38fab89463
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
outer_wrapper.py
View File

@@ -197,7 +197,7 @@ class OuterWrapper(ABC):
)
logging.basicConfig(
level=logging.DEBUG,
level=logging.INFO,
stream=sys.stdout,
format='%(asctime)s - %(levelname)s - %(filename)s:%(funcName)s:%(lineno)d - %(message)s',
)
@@ -517,7 +517,7 @@ class OuterWrapper(ABC):
for name, schema in self.output_schemas.items():
try:
validate(message['payload'], schema)
logging.info(f"validated outgoing message: {message}")
logging.info(f"validated outgoing message from {message['source']}")
matched.append(schema)
# translate each data variable to output schema's granularity
@@ -557,11 +557,11 @@ class OuterWrapper(ABC):
message['payload'][item]['granularity'] = dest_gran
except ValidationError:
logging.info("validation error")
logging.debug("validation error")
except json.JSONDecodeError:
logging.warning("json decode error")
if len(matched) == 0:
logging.info(
logging.debug(
f"message didn't match any output schemas: {message['source']}"
)
elif len(matched) == 1:
@@ -598,7 +598,7 @@ class OuterWrapper(ABC):
message = sock.recv_json()
except zmq.ZMQError:
continue
logging.info(json.dumps(message))
logging.debug(json.dumps(message))
signal = message.get('signal')
if signal == 'status' and message.get('source') == 'broker':
@@ -627,7 +627,7 @@ class OuterWrapper(ABC):
try:
validate(message['payload'], schema)
logging.info(
f"schema {name} validated incoming message: {message}"
f"schema {name} validated incoming message from {message['source']}"
)
if name in self.validated_schemas:
logging.error(
@@ -675,12 +675,12 @@ class OuterWrapper(ABC):
self.validated_schemas[name] = message['payload']
except ValidationError:
logging.info("validation error")
logging.debug("validation error")
except json.JSONDecodeError:
logging.warning("json decode error")
if len(matched) == 0:
logging.info(
logging.debug(
f"message didn't match any input schemas: {message['source']}"
)
return True