FlexMeasures / flexmeasures / 26160184233

push

github

Move sensor data ingestion to job queue (#2101)

* Initial plan

* Move data ingestion logic to job queue (ingestion queue)

Agent-Logs-Url: https://github.com/FlexMeasures/flexmeasures/sessions/d8f1f856-844d-4274-a34b-36e33e6d8f69

Co-authored-by: joshuaunity <45713692+joshuaunity@users.noreply.github.com>

* Fix code review comments: use for loop and move imports to module level

Agent-Logs-Url: https://github.com/FlexMeasures/flexmeasures/sessions/d8f1f856-844d-4274-a34b-36e33e6d8f69

Co-authored-by: joshuaunity <45713692+joshuaunity@users.noreply.github.com>

* Add warning when ingestion queue is not configured

Agent-Logs-Url: https://github.com/FlexMeasures/flexmeasures/sessions/a05e0a24-6919-4080-a466-cbaf6a8369de

Co-authored-by: joshuaunity <45713692+joshuaunity@users.noreply.github.com>

* docs: add changelog entry and upgrade notice for ingestion queue warning (PR #2101)

Agent-Logs-Url: https://github.com/FlexMeasures/flexmeasures/sessions/2383b9c6-1167-413c-9cf0-e31f2a9db9f5

Co-authored-by: joshuaunity <45713692+joshuaunity@users.noreply.github.com>

* chore: remvoe wrong log entry

Signed-off-by: joshuaunity <oghenerobojosh01@gmail.com>

* docs: add ingestion queue changelog entry and upgrade notice to v0.33.0

Agent-Logs-Url: https://github.com/FlexMeasures/flexmeasures/sessions/3eae55cb-3902-4be8-84f7-76436f33cdd6

Co-authored-by: joshuaunity <45713692+joshuaunity@users.noreply.github.com>

* chore: remove duplicate changelog entry

Signed-off-by: joshuaunity <oghenerobojosh01@gmail.com>

* fix: update job queue command to include ingestion

Signed-off-by: joshuaunity <oghenerobojosh01@gmail.com>

* docs: add ingestion queue to worker examples in forecasting_scheduling docs

Agent-Logs-Url: https://github.com/FlexMeasures/flexmeasures/sessions/c290f889-38c7-4f48-b96b-72f918051281

Co-authored-by: joshuaunity <45713692+joshuaunity@users.noreply.github.com>

* refactor: update data ingestion logic to enqueue forecasting jobs

Signed-off... (continued)

187 of 209 new or added lines in 16 files covered. (89.47%)

12759 of 15857 relevant lines covered (80.46%)

0.8 hits per line