diff --git a/app/subscriptions.py b/app/subscriptions.py index 5d3ba77..ab2ecfd 100755 --- a/app/subscriptions.py +++ b/app/subscriptions.py @@ -23,6 +23,7 @@ def __init__(self, r: Redis, channels): def run(self): logging.info("listener run") for item in self.pubsub.listen(): + logging.info(f"listener item: {item}") if item["type"] == "message" and item["channel"] == self.KILL_PILL.encode(): break @@ -41,6 +42,7 @@ def run(self): logging.error(f"\nRequest prompt:\n{data["text"]}\n\nError:\n{error_traceback}") answer = f"error on {data["id"]} request, please resend prompt later." + logging.info(f"send answer to {data['id']}") self.redis.set( name=data["id"], # key value=answer, # model output