From a74c28b63ed4f556995537efe0153b6ab93eac93 Mon Sep 17 00:00:00 2001 From: "Juan M. Ley" Date: Sat, 21 Mar 2026 12:45:40 -0600 Subject: [PATCH] I'm kinda dumb and fought with this thing instead of just instancing the consumers directly --- src/main.py | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/src/main.py b/src/main.py index e466b6a..7f608f9 100644 --- a/src/main.py +++ b/src/main.py @@ -4,6 +4,8 @@ Ejecuta dos APIs en paralelo: Usuarios (puerto 8000) y Reportes (puerto 8001) """ from infrastructure.api.users.app import create_app as create_users_app from infrastructure.api.reports.app import create_app as create_reports_app +from consumers.report_consumer import ReportConsumer +from consumers.user_consumer import UserConsumer from core.config import ConfSettings import threading import uvicorn @@ -30,6 +32,15 @@ def run_reports_api(): log_level=ConfSettings.log_level, ) +def run_user_consumer(): + consumer = UserConsumer() + consumer.start() + +def run_reports_consumer(): + consumer = ReportConsumer() + consumer.start() + + def run(): """Inicia ambas APIs en threads separados""" print("=" * 60) @@ -38,9 +49,14 @@ def run(): users_thread = threading.Thread(target=run_users_api, daemon=True, name="Users-API") reports_thread = threading.Thread(target=run_reports_api, daemon=True, name="Reports-API") + user_consumer_thread = threading.Thread(target=run_user_consumer, daemon=True, name="Users-Consumer") + report_consumer_thread = threading.Thread(target=run_reports_consumer, daemon=True, name="Reports-Consumer") + users_thread.start() reports_thread.start() + user_consumer_thread.start() + report_consumer_thread.start() print("\n✓ API de Usuarios ejecutándose en http://0.0.0.0:8000") print("✓ API de Reportes ejecutándose en http://0.0.0.0:8001")