Closed amindadgar closed 6 days ago
[!CAUTION]
Review failed
The pull request is closed.
The changes in this pull request focus on the dags/hivemind_telegram_etl.py
file, specifically modifying the processor
function within the create_telegram_dag
factory function. The date_schema
variable is now consistently set to models.PayloadSchemaType.FLOAT
for both message and summary processing. The logic for message extraction has been refined, introducing conditional checks based on latest_date
and dag_type
, affecting how data is retrieved for messages and summaries. The overall structure and task dependencies of the DAG remain unchanged.
File Path | Change Summary |
---|---|
dags/hivemind_telegram_etl.py | - Modified processor function to set date_schema to models.PayloadSchemaType.FLOAT for both processing types.- Refined message extraction logic with conditional checks based on latest_date and dag_type . |
processor
function in dags/hivemind_telegram_etl.py
, impacting how data is handled and structured, which is closely related to the changes made in the main PR.SummarizeMessages
class in dags/hivemind_telegram_etl.py
, which is directly related to the summarization logic altered in the main PR.TransformSummary
class in dags/hivemind_etl_helpers/src/db/telegram/transform/summary.py
, which is relevant to the changes made in the main PR regarding the handling of summary data.🐰 In the land of code, where rabbits hop,
Changes were made, and we won’t stop!
With schemas set right, and messages clear,
Our DAG now dances, let’s give a cheer!
From dates we extract, both old and new,
Hooray for the changes, we’re coding anew! 🌟
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
Summary by CodeRabbit
New Features
Bug Fixes