mirror of https://github.com/CIRCL/AIL-framework
More cleanup
parent
fca00beed9
commit
46f27ada4e
|
@ -55,6 +55,7 @@ if __name__ == "__main__":
|
||||||
|
|
||||||
message = p.get_from_set()
|
message = p.get_from_set()
|
||||||
prec_filename = None
|
prec_filename = None
|
||||||
|
generate_new_graph = False
|
||||||
while True:
|
while True:
|
||||||
if message is not None:
|
if message is not None:
|
||||||
generate_new_graph = True
|
generate_new_graph = True
|
||||||
|
|
|
@ -36,12 +36,6 @@ def main():
|
||||||
publisher.port = 6380
|
publisher.port = 6380
|
||||||
publisher.channel = "Queuing"
|
publisher.channel = "Queuing"
|
||||||
|
|
||||||
# ZMQ #
|
|
||||||
channel = cfg.get("PubSub_Global", "channel")
|
|
||||||
|
|
||||||
# FUNCTIONS #
|
|
||||||
publisher.info("""Suscribed to channel {0}""".format(channel))
|
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
table = texttable.Texttable()
|
table = texttable.Texttable()
|
||||||
table.header(["Queue name", "#Items"])
|
table.header(["Queue name", "#Items"])
|
||||||
|
|
|
@ -31,7 +31,7 @@ if __name__ == "__main__":
|
||||||
db=p.config.getint("Redis_Cache", "db"))
|
db=p.config.getint("Redis_Cache", "db"))
|
||||||
|
|
||||||
# Country to log as critical
|
# Country to log as critical
|
||||||
cc_critical = p.config.get("PubSub_Url", "cc_critical")
|
cc_critical = p.config.get("Url", "cc_critical")
|
||||||
|
|
||||||
# FUNCTIONS #
|
# FUNCTIONS #
|
||||||
publisher.info("Script URL subscribed to channel web_categ")
|
publisher.info("Script URL subscribed to channel web_categ")
|
||||||
|
|
Loading…
Reference in New Issue