From 37bffd5ce8dfb208f33e0bcedaa650b61e02f14a Mon Sep 17 00:00:00 2001 From: Marco Zeisler Date: Thu, 27 May 2021 19:41:55 +0200 Subject: [PATCH] pass redis instance --- components/event_store/event_logger.py | 6 ++++++ components/event_store/event_store_server.py | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/components/event_store/event_logger.py b/components/event_store/event_logger.py index a3ba3fe..fe41eac 100644 --- a/components/event_store/event_logger.py +++ b/components/event_store/event_logger.py @@ -1,9 +1,15 @@ import pickle +from flask_redis import Redis from shared.message_broker_wrapper import MBWrapper class EventLogger: + redis: Redis + + def __init__(self, redis): + self.redis = redis + @staticmethod def log(msg): try: diff --git a/components/event_store/event_store_server.py b/components/event_store/event_store_server.py index 2cce47f..13c5ddd 100644 --- a/components/event_store/event_store_server.py +++ b/components/event_store/event_store_server.py @@ -25,6 +25,6 @@ def home_page(): if __name__ == '__main__': - el = EventLogger() + el = EventLogger(redis) threading.Thread(target=el.setup_msq_queue).start() threading.Thread(target=app.run).start()