GovOPlaN/govoplan-core
1
0
Fork 0
Code Issues 43 Pull Requests Actions Packages Projects Releases Wiki Activity

fix(notifications): commit worker delivery transactions

Browse Source
This commit is contained in:
Albrecht Degering
2026-07-20 20:03:21 +02:00
parent 1a29e75db4
commit 28afc01371
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/govoplan_core/celery_app.py
View File

@@ -121,7 +121,9 @@ def deliver_notification(self, notification_id: str):
from govoplan_core.db.session import get_database from govoplan_core.db.session import get_database
with get_database().SessionLocal() as session: with get_database().SessionLocal() as session:
return dict(_notification_dispatch().deliver_notification(session, notification_id=notification_id)) result = dict(_notification_dispatch().deliver_notification(session, notification_id=notification_id))
session.commit()
return result
@celery.task(name="govoplan.notifications.deliver_pending", bind=True, max_retries=0) @celery.task(name="govoplan.notifications.deliver_pending", bind=True, max_retries=0)
@@ -129,7 +131,9 @@ def deliver_pending_notifications(self, tenant_id: str | None = None, limit: int
from govoplan_core.db.session import get_database from govoplan_core.db.session import get_database
with get_database().SessionLocal() as session: with get_database().SessionLocal() as session:
return dict(_notification_dispatch().deliver_pending(session, tenant_id=tenant_id, limit=limit)) result = dict(_notification_dispatch().deliver_pending(session, tenant_id=tenant_id, limit=limit))
session.commit()
return result
@celery.task(name="govoplan.calendar.dispatch_outbox", bind=True, max_retries=0) @celery.task(name="govoplan.calendar.dispatch_outbox", bind=True, max_retries=0)