Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: asyncpg adapter #177

Closed
wants to merge 13 commits into from
Prev Previous commit
Next Next commit
feat: upstream changes
cofin committed Oct 13, 2024
commit fb4bfef1f0f0060532cb87890d70e55783e89ec4
2 changes: 1 addition & 1 deletion saq/queue/postgres.py
Original file line number Diff line number Diff line change
@@ -833,4 +833,4 @@ async def _start(self) -> None:

async for notify in conn.notifies():
payload = json.loads(notify.payload)
self.publish(payload["key"], payload)
self.publish(payload["key"], payload)