Skip to content

Commit 15a9330

Browse files
committed
Fix close_voting().
1 parent fa97515 commit 15a9330

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

karmabot/karma_manager.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -99,12 +99,13 @@ def remove_old_votings(self) -> None:
9999
session.delete(o)
100100

101101
def close_voting(self, voting: Voting, reactions: Counter[str] | None = None) -> bool:
102-
success = False
103102
with self._session_maker.begin() as session:
104103
if reactions is None:
105104
logger.error("Failed to get messages for: %s", voting)
106105
session.delete(voting)
107-
elif self._determine_success(reactions):
106+
return False
107+
success = self._determine_success(reactions)
108+
if success:
108109
stmt = sa.select(Karma).filter_by(user_id=voting.target_id)
109110
karma = session.execute(stmt).scalar_one_or_none()
110111
if karma is not None:
@@ -114,10 +115,9 @@ def close_voting(self, voting: Voting, reactions: Counter[str] | None = None) ->
114115
user_id=voting.target_id, karma=self._initial_value + voting.karma
115116
)
116117
session.add(new_record)
117-
success = True
118-
update_stmt = sa.update(Voting).where(Voting.id == voting.id).values(closed=True)
119-
session.execute(update_stmt)
120-
return success
118+
update_stmt = sa.update(Voting).where(Voting.id == voting.id).values(closed=True)
119+
session.execute(update_stmt)
120+
return success
121121

122122
def _determine_success(self, reactions: Counter[str]) -> bool:
123123
logger.info("Reactions: %s", reactions)

0 commit comments

Comments
 (0)