From 737c56122793b75a135f7b81e1b4aa6399c3cf18 Mon Sep 17 00:00:00 2001 From: Carlos Quintana <74399022+cquintana92@users.noreply.github.com> Date: Fri, 23 Aug 2024 09:11:47 +0200 Subject: [PATCH] fix: specify default dispatcher in job runner (#2191) --- job_runner.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/job_runner.py b/job_runner.py index 1c3fdd3a..8cd77baa 100644 --- a/job_runner.py +++ b/job_runner.py @@ -14,6 +14,7 @@ from app.email_utils import ( send_email, render, ) +from app.events.event_dispatcher import PostgresDispatcher from app.import_utils import handle_batch_import from app.jobs.event_jobs import send_alias_creation_events_for_user from app.jobs.export_user_data_job import ExportUserDataJob @@ -276,7 +277,9 @@ SimpleLogin team. user = User.get(user_id) if user and user.activated: LOG.d(f"Sending alias creation events for {user}") - send_alias_creation_events_for_user(user) + send_alias_creation_events_for_user( + user, dispatcher=PostgresDispatcher.get() + ) else: LOG.e("Unknown job name %s", job.name)