From bbc5782a5332aa96e8b5988e63320a6080649d64 Mon Sep 17 00:00:00 2001 From: Mohammad Amin Date: Mon, 12 Aug 2024 16:37:52 +0330 Subject: [PATCH 1/2] feat: Added publish message for discord! --- dags/analyzer_helper/common/analyzer.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/dags/analyzer_helper/common/analyzer.py b/dags/analyzer_helper/common/analyzer.py index 3d7caaa8..433fc0b1 100644 --- a/dags/analyzer_helper/common/analyzer.py +++ b/dags/analyzer_helper/common/analyzer.py @@ -5,6 +5,7 @@ from tc_analyzer_lib.schemas.platform_configs import DiscordAnalyzerConfig from tc_analyzer_lib.schemas.platform_configs.config_base import PlatformConfigBase from tc_analyzer_lib.tc_analyzer import TCAnalyzer +from tc_analyzer_lib.publish_on_success import publish_on_success class Analyzer: @@ -34,3 +35,6 @@ def analyze( else: logging.info(f"{prefix} append analytics to previous analytics results!") asyncio.run(analyzer.run_once()) + + # this will just support discord platform + publish_on_success(platform_id, recompute) From dde1a8fc1d25bee918307e0f77d436b4a0792abf Mon Sep 17 00:00:00 2001 From: Mohammad Amin Date: Mon, 12 Aug 2024 16:51:19 +0330 Subject: [PATCH 2/2] fix: isort linter issue! --- dags/analyzer_helper/common/analyzer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dags/analyzer_helper/common/analyzer.py b/dags/analyzer_helper/common/analyzer.py index 433fc0b1..cf25c7f6 100644 --- a/dags/analyzer_helper/common/analyzer.py +++ b/dags/analyzer_helper/common/analyzer.py @@ -2,10 +2,10 @@ import logging from datetime import datetime +from tc_analyzer_lib.publish_on_success import publish_on_success from tc_analyzer_lib.schemas.platform_configs import DiscordAnalyzerConfig from tc_analyzer_lib.schemas.platform_configs.config_base import PlatformConfigBase from tc_analyzer_lib.tc_analyzer import TCAnalyzer -from tc_analyzer_lib.publish_on_success import publish_on_success class Analyzer: