projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Reformat files according to new black validation
[osm/MON.git]
/
osm_mon
/
cmd
/
mon_utils.py
diff --git
a/osm_mon/cmd/mon_utils.py
b/osm_mon/cmd/mon_utils.py
index
83dd130
..
88e7500
100644
(file)
--- a/
osm_mon/cmd/mon_utils.py
+++ b/
osm_mon/cmd/mon_utils.py
@@
-22,7
+22,6
@@
import kafka
def wait_till_commondb_is_ready(config, process_name="osm-mon", commondb_wait_time=5):
def wait_till_commondb_is_ready(config, process_name="osm-mon", commondb_wait_time=5):
-
logging.debug("wait_till_commondb_is_ready")
while True:
logging.debug("wait_till_commondb_is_ready")
while True:
@@
-39,7
+38,6
@@
def wait_till_commondb_is_ready(config, process_name="osm-mon", commondb_wait_ti
def wait_till_kafka_is_ready(config, process_name="osm-mon", kafka_wait_time=5):
def wait_till_kafka_is_ready(config, process_name="osm-mon", kafka_wait_time=5):
-
logging.debug("wait_till_kafka_is_ready")
while True:
logging.debug("wait_till_kafka_is_ready")
while True:
@@
-98,7
+96,6
@@
def wait_till_kafka_is_ready(config, process_name="osm-mon", kafka_wait_time=5):
def wait_till_core_services_are_ready(
config, process_name="osm-mon", commondb_wait_time=5, kafka_wait_time=5
):
def wait_till_core_services_are_ready(
config, process_name="osm-mon", commondb_wait_time=5, kafka_wait_time=5
):
-
logging.debug("wait_till_core_services_are_ready")
if not config:
logging.debug("wait_till_core_services_are_ready")
if not config: