diff --git a/src/snek/service/notification.py b/src/snek/service/notification.py index 5a301a8..399a0a1 100644 --- a/src/snek/service/notification.py +++ b/src/snek/service/notification.py @@ -39,7 +39,6 @@ class NotificationService(BaseService): if not channel_member['new_count']: channel_member['new_count'] = 0 channel_member['new_count'] += 1 - print("INSERTED!!",flush=True) await self.services.channel_member.save(channel_member) model = await self.new() diff --git a/src/snek/system/mapper.py b/src/snek/system/mapper.py index d7e4163..e57b0fa 100644 --- a/src/snek/system/mapper.py +++ b/src/snek/system/mapper.py @@ -49,6 +49,7 @@ class BaseMapper: if not model.record.get("uid"): raise Exception(f"Attempt to save without uid: {model.record}.") model.updated_at.update() + print(model.record,flush=True) return self.table.upsert(model.record, ["uid"]) async def find(self, **kwargs) -> typing.AsyncGenerator: