Minor cleanups
diff --git a/voltha/main.py b/voltha/main.py
index 3f63a9c..e76fac3 100755
--- a/voltha/main.py
+++ b/voltha/main.py
@@ -30,13 +30,13 @@
from voltha.coordinator import Coordinator
from voltha.dockerhelpers import get_my_containers_name
-from voltha.nethelpers import get_my_primary_interface, get_my_primary_local_ipv4
+from voltha.nethelpers import get_my_primary_interface, \
+ get_my_primary_local_ipv4
from voltha.northbound.grpc.grpc_server import VolthaGrpcServer
from voltha.northbound.rest.health_check import init_rest_service
from voltha.structlog_setup import setup_logging
from voltha.northbound.kafka.kafka_proxy import KafkaProxy, get_kafka_proxy
-
defs = dict(
config=os.environ.get('CONFIG', './voltha.yml'),
consul=os.environ.get('CONSUL', 'localhost:8500'),
@@ -54,7 +54,6 @@
def parse_args():
-
parser = argparse.ArgumentParser()
_help = ('Path to voltha.yml config file (default: %s). '
@@ -87,7 +86,7 @@
action='store',
default=defs['grpc_port'],
help=_help)
-
+
_help = ('<hostname>:<port> to fluentd server (default: %s). (If not '
'specified (None), the address from the config file is used'
% defs['fluentd'])
@@ -204,7 +203,6 @@
class Main(object):
-
def __init__(self):
self.args = args = parse_args()
@@ -219,6 +217,7 @@
# components
self.coordinator = None
self.grpc_server = None
+ self.kafka_proxy = None
if not args.no_banner:
print_banner(self.log)
@@ -244,7 +243,7 @@
self.grpc_server = VolthaGrpcServer(self.args.grpc_port).run()
- #initialize kafka proxy singleton
+ # initialize kafka proxy singleton
self.kafka_proxy = KafkaProxy(self.args.consul, self.args.kafka)
self.log.info('started-internal-services')
@@ -291,5 +290,6 @@
lc = LoopingCall(get_kafka_proxy().send_message, topic, message)
lc.start(10)
+
if __name__ == '__main__':
Main().start()