flexmeasures.data.services.reporting

Logic for queueing and running reporting jobs.

Functions

flexmeasures.data.services.reporting.create_reporting_job(reporter: Reporter, queue: str = 'reporting') → Job

Queue a job that computes a report and stores its results.

flexmeasures.data.services.reporting.run_report_job(data_source_id: int, parameters: dict) → list[dict]

Compute and store a report in a reporting worker.