We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7ab8ae8 commit f113cd1Copy full SHA for f113cd1
src/aleph/jobs/fetch_pending_messages.py
@@ -134,7 +134,7 @@ async def fetch_pending_messages(
134
yield fetched_messages
135
fetched_messages = []
136
137
- if not PendingMessageDb.count(session):
+ if not await PendingMessageDb.count(session):
138
# If not in loop mode, stop if there are no more pending messages
139
if not loop:
140
break
0 commit comments