from api import app from utils.async_helpers import fire_and_forget from utils.reporting.slack_reporter import SlackReporter class WorkerLogger: slack_reporter = SlackReporter() def debug(self, title: str, message: str): app.logger.info(f"[{title}] {message}") def info(self, title: str, message: str): app.logger.info(f"[{title}] {message}") fire_and_forget(self.slack_reporter.notify_info(title, message)) def success(self, title: str, message: str): app.logger.info(f"[{title}] {message}") fire_and_forget(self.slack_reporter.notify_success(title, message)) def error(self, title: str, message: str): app.logger.error(f"[{title}] {message}") fire_and_forget(self.slack_reporter.notify_error(title, message))