19 lines
449 B
Python
19 lines
449 B
Python
from src.daemons.base import BaseDaemon
|
|
from src.messaging.consumers.consumers import (
|
|
reset_email_consumer,
|
|
welcome_email_consumer,
|
|
)
|
|
|
|
|
|
class WelcomeEmailDaemon(BaseDaemon):
|
|
name = "welcome_email"
|
|
|
|
async def run(self) -> None:
|
|
await welcome_email_consumer.start_consuming()
|
|
|
|
|
|
class ResetEmailDaemon(BaseDaemon):
|
|
name = "reset_email"
|
|
|
|
async def run(self) -> None:
|
|
await reset_email_consumer.start_consuming() |