Commit d05877e4 authored by Patrick Godwin's avatar Patrick Godwin

aggregator.py: fix typo in store_triggers, remove logging setup as it is ignored

parent ac079d34
Pipeline #77104 passed with stages
in 3 minutes and 19 seconds
......@@ -85,12 +85,6 @@ def main(args=None):
with open(config_path, 'r') as f:
config = yaml.safe_load(f)
### set up logging
logging.basicConfig(
level = logging.INFO,
format = "%(asctime)s %(levelname)s:%(processName)s(%(process)d):%(funcName)s: %(message)s"
)
# instantiate a consumer to subscribe to all of our topics, i.e., jobs
consumer = KafkaConsumer(
*schemas,
......@@ -136,7 +130,7 @@ def main(args=None):
elif args.data_type == 'triggers':
far_key = config['schemas'][schema]['far_key']
time_key = config['schemas'][schema]['time_key']
aggregator.store_triggers(schema, [trg for trg in triggers if far_key in trg], far_key = far_key, time_key = time_key)
aggregator.store_triggers(schema, [trg for trg in data if far_key in trg], far_key = far_key, time_key = time_key)
store_elapsed = timeit.default_timer() - start
logging.info("time to store/reduce %s: %.1f s" % (args.data_type, store_elapsed))
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment