projects
/
osm
/
POL.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fixes StopIteration error in multi scaling group descriptor scenarios
[osm/POL.git]
/
osm_policy_module
/
cmd
/
policy_module_agent.py
diff --git
a/osm_policy_module/cmd/policy_module_agent.py
b/osm_policy_module/cmd/policy_module_agent.py
index
1b6b93a
..
c82f006
100644
(file)
--- a/
osm_policy_module/cmd/policy_module_agent.py
+++ b/
osm_policy_module/cmd/policy_module_agent.py
@@
-43,7
+43,7
@@
def main():
datefmt='%m/%d/%Y %I:%M:%S %p',
level=logging.getLevelName(cfg.OSMPOL_LOG_LEVEL))
kafka_logger = logging.getLogger('kafka')
datefmt='%m/%d/%Y %I:%M:%S %p',
level=logging.getLevelName(cfg.OSMPOL_LOG_LEVEL))
kafka_logger = logging.getLogger('kafka')
- kafka_logger.setLevel(logging.
WARN
)
+ kafka_logger.setLevel(logging.
getLevelName(cfg.OSMPOL_KAFKA_LOG_LEVEL)
)
kafka_formatter = logging.Formatter(log_formatter_str)
kafka_handler = logging.StreamHandler(sys.stdout)
kafka_handler.setFormatter(kafka_formatter)
kafka_formatter = logging.Formatter(log_formatter_str)
kafka_handler = logging.StreamHandler(sys.stdout)
kafka_handler.setFormatter(kafka_formatter)