changed tap invalid format logging level to debug (instead of warning)

FORTH-ICS-INSPIRE · Mar 25, 2021 · 8c69eb8 · 8c69eb8
1 parent 28166db
commit 8c69eb8
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 9 deletions.
diff --git a/docs/changelog.md b/docs/changelog.md
@@ -14,6 +14,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - upgraded artemis-utils to 1.0.10 to include the slacker-log-handler==1.7.1 dep
 - migrating from travis to GH actions
 - downgraded to six==1.11.0 to achieve compatibility
+- changed tap invalid format logging level to debug (instead of warning)
 
 ### Fixed
 - autoconfiguration subprefix bug in prefixtree plus new autoconf tests

diff --git a/monitor-services/bgpstreamhisttap/core/bgpstreamhist.py b/monitor-services/bgpstreamhisttap/core/bgpstreamhist.py
@@ -437,7 +437,7 @@ def run(self):
                                                 )
                                                 time.sleep(0.01)
                                         else:
-                                            log.warning(
+                                            log.debug(
                                                 "Invalid format message: {}".format(msg)
                                             )
                                     except BaseException:

diff --git a/monitor-services/bgpstreamkafkatap/core/bgpstreamkafka.py b/monitor-services/bgpstreamkafkatap/core/bgpstreamkafka.py
@@ -526,9 +526,7 @@ def run(self):
                                             serializer="ujson",
                                         )
                                 else:
-                                    log.warning(
-                                        "Invalid format message: {}".format(msg)
-                                    )
+                                    log.debug("Invalid format message: {}".format(msg))
                             except BaseException:
                                 log.exception(
                                     "Error when normalizing BGP message: {}".format(msg)

diff --git a/monitor-services/bgpstreamlivetap/core/bgpstreamlive.py b/monitor-services/bgpstreamlivetap/core/bgpstreamlive.py
@@ -501,9 +501,7 @@ def run(self):
                                             serializer="ujson",
                                         )
                                 else:
-                                    log.warning(
-                                        "Invalid format message: {}".format(msg)
-                                    )
+                                    log.debug("Invalid format message: {}".format(msg))
                             except BaseException:
                                 log.exception(
                                     "Error when normalizing BGP message: {}".format(msg)

diff --git a/monitor-services/exabgptap/core/exabgp_client.py b/monitor-services/exabgptap/core/exabgp_client.py
@@ -542,7 +542,7 @@ def handle_exabgp_msg(bgp_message):
                                             serializer="ujson",
                                         )
                         else:
-                            log.warning("Invalid format message: {}".format(msg))
+                            log.debug("Invalid format message: {}".format(msg))
                     except BaseException:
                         log.exception(
                             "Error when normalizing BGP message: {}".format(msg)

diff --git a/monitor-services/riperistap/core/ripe_ris.py b/monitor-services/riperistap/core/ripe_ris.py
@@ -451,7 +451,7 @@ def run(self):
                                                     serializer="ujson",
                                                 )
                                         else:
-                                            log.warning(
+                                            log.debug(
                                                 "Invalid format message: {}".format(msg)
                                             )
                                     except BaseException: