CleanGuestlineTask — Developer Reference

Developer reference for CleanGuestlineTask used to transform Raw* Guestline models into Clean* models for Queensway.

File: etl_lib/tasks/chains/guestline/CleanGuestlineTask.py

Constructor Parameters

Parameter	Type	Description
`name`	`Optional[str]`	Custom task name
`job_context`	`JobContext`	Job context with Spark session and config
`**kwargs`	`dict`	Extra Task kwargs


from etl_lib.tasks.chains.guestline.CleanGuestlineTask import CleanGuestlineTask
 
task = CleanGuestlineTask(job_context=job_context)
 
task.run()

Key implementations:

Deduplicate reservations using a status priority and latest lasteditedtimestamp timestamp
Create res_id and guest_id UUIDs when not present in payloads
Enrich guest profiles by joining RawPersonprofilesModel to reservations
Explode ratelines to create daily room records with distributed revenue and stay dates
Apply cleaning helpers for address/country/email/phone normalization

Back to tasks: /processes/tasks/chains/guestline/clean-guestline-task