adp.maintain.rules.run_retention_rule

adp.maintain.rules.run_retention_rule(rule: RetentionRule, datasource: DataSource) → DeltaTable | None

Run Apply retentionrule on the dataframe

Parameters:

datasource (DataSource) – DataSource object which refers to a delta location in our datalake

Raises:

ColumnNotInDataframeException – If the column on which the retentionrule needs to run on does not exist

Returns:

Return the Delta table, NOT a dataframe!

Return type:

DeltaTable