Closed amindadgar closed 3 weeks ago
The changes involve modifications to the get_latest_document_date
method within the CustomIngestionPipeline
class in dags/hivemind_etl_helpers/ingestion_pipeline.py
. The method's signature has been updated to include an additional parameter, field_schema
, which allows for dynamic specification of the schema type for indexing. This parameter is now passed to the _create_payload_index
method, replacing a hardcoded value. The overall control flow, logging, and error handling remain unchanged.
File Path | Change Summary |
---|---|
dags/hivemind_etl_helpers/ingestion_pipeline.py | Updated get_latest_document_date method to include field_schema parameter for flexibility. |
In the code where rabbits play,
A new field joins the fray,
With schemas bright, they hop along,
Making pipelines sing a song.
Flexibility's the name of the game,
In our code, we’ll never be the same! 🐇✨
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