projects
/
osm
/
POL.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Implements aiokafka and modifies code to support asyncio
[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
c82f006
..
49c7d3a
100644
(file)
--- a/
osm_policy_module/cmd/policy_module_agent.py
+++ b/
osm_policy_module/cmd/policy_module_agent.py
@@
-21,7
+21,7
@@
# For those usages not covered by the Apache License, Version 2.0 please
# contact: bdiaz@whitestack.com or glavado@whitestack.com
##
# For those usages not covered by the Apache License, Version 2.0 please
# contact: bdiaz@whitestack.com or glavado@whitestack.com
##
-import a
rgparse
+import a
syncio
import logging
import sys
import logging
import sys
@@
-32,11
+32,6
@@
from osm_policy_module.core.database import DatabaseManager
def main():
cfg = Config.instance()
def main():
cfg = Config.instance()
- parser = argparse.ArgumentParser(prog='pm-scaling-config-agent')
- parser.add_argument('--config-file', nargs='?', help='Policy module agent configuration file')
- args = parser.parse_args()
- if args.config_file:
- cfg.load_file(args.config_file)
log_formatter_str = '%(asctime)s - %(name)s - %(levelname)s - %(message)s'
logging.basicConfig(stream=sys.stdout,
format=log_formatter_str,
log_formatter_str = '%(asctime)s - %(name)s - %(levelname)s - %(message)s'
logging.basicConfig(stream=sys.stdout,
format=log_formatter_str,
@@
-55,7
+50,8
@@
def main():
db_manager.create_tables()
log.info("Database synced correctly.")
log.info("Starting policy module agent...")
db_manager.create_tables()
log.info("Database synced correctly.")
log.info("Starting policy module agent...")
- agent = PolicyModuleAgent()
+ loop = asyncio.get_event_loop()
+ agent = PolicyModuleAgent(loop)
agent.run()
agent.run()