ayan-kohli opened a new pull request, #63637: URL: https://github.com/apache/airflow/pull/63637
### Summary Implements DB persistence layer for FlowRate task metrics as part of Sprint 2, allowing for storing per-task resource and cost data in Airflow's database. ### Changes `airflow/models/flowrate_metric.py` - new SQLAlchemy model with fields and a composite index on three main keys `airflow/migrations/versions/9f3b2c1d4e5f_add_flowrate_metric.py` - Alembic migration to create/update/drop `flowrate_metric` table `airflow/plugins/flowrate/persistence.py` - integrates persistence option with Airflow session via a function `save_task_metric()` that would be called by a listener `tests/unit/plugins/flowrate/test_persistence.py` - unit tests for insert, handling, and graceful failure `Makefile` - use command `make test-flowrate` for easier test runs in the future -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
