DailyReportTask — Developer Reference

Developer-facing implementation and example code for DailyReportTask.

Example Usage

from etl_lib.tasks.reports.DailyReportTask import DailyReportTask
 
task = DailyReportTask(
    job_context=job_context,
    database_sink=sink
)
 
task.run()

Incremental example

task = DailyReportTask(job_context=job_context, database_sink=sink, is_incremental=True, write_to_catalog=True)
task.run()

In incremental execution the task will regenerate daily rows affected by the ProcessedAddedRoomModel and upsert them into the chain table using keys: chain_id, property_id, res_id, room_stay_date.

Use Case Examples

Daily occupancy pivot and aggregated metrics

daily_report = processed_rooms_df.groupBy(
    "property_id", "room_stay_date"
).agg(
    F.sum("room_stay_date_total_net").alias("total_revenue")
)

Back to process documentation: /processes/tasks/reports/daily-report-task