Merge pull request #300 from TogetherCrew/feat/analyzer-helpers-telegram

fix: updated to use telegram config!

dags/telegram_analyzer_etl.py

@@ -12,6 +12,7 @@
 from analyzer_helper.telegram.transform_raw_data import TransformRawInfo
 from analyzer_helper.telegram.transform_raw_members import TransformRawMembers
 from dateutil.parser import parse
+from tc_analyzer_lib.schemas.platform_configs import TelegramAnalyzerConfig
 
 with DAG(
     dag_id="telegram_analyzer_etl",
@@ -199,11 +200,10 @@ def analyze_telegram(platform_processed: dict[str, str | bool]) -> None:
 
         platform_data = fetcher.fetch_analyzer_parameters(platform_id)
 
-        metadata = platform_data["metadata"]
-        period = metadata["period"]
-        action = metadata["action"]
-        window = metadata["window"]
-        resources = metadata["resources"]
+        period = platform_data["period"]
+        action = platform_data["action"]
+        window = platform_data["window"]
+        resources = platform_data["resources"]
 
         analyzer = Analyzer()
 
@@ -214,6 +214,8 @@ def analyze_telegram(platform_processed: dict[str, str | bool]) -> None:
             action=action,
             window=window,
             recompute=recompute,
+            config=TelegramAnalyzerConfig(),
+            send_completed_message=False,
         )
 
     platform_modules = fetch_telegram_platforms()

requirements.txt

@@ -21,4 +21,4 @@ redis===5.0.4
 tc-wikipedia-lib==1.0.1
 llama-index-readers-file==0.1.22
 docx2txt==0.8
-tc-analyzer-lib==1.4.10
+tc-analyzer-lib==1.4.11