Skip to content

Commit 64c1b98

Browse files
committed
fix: missing await for .count()
1 parent f90b7d5 commit 64c1b98

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/aleph/jobs/fetch_pending_messages.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ async def fetch_pending_messages(
134134
yield fetched_messages
135135
fetched_messages = []
136136

137-
if not PendingMessageDb.count(session):
137+
if not await PendingMessageDb.count(session):
138138
# If not in loop mode, stop if there are no more pending messages
139139
if not loop:
140140
break

0 commit comments

Comments
 (0)