1- import datetime as dt
21import logging
32from dataclasses import dataclass
43
1312
1413
1514@dataclass (frozen = True , kw_only = True )
16- class HistoricalRecord :
15+ class Historical :
1716 workspace_id : int
18- """The identifier of the workspace where this record was generated."""
17+ """The identifier of the workspace where this historical record was generated."""
1918
2019 job_run_id : int
21- """The identifier of the job run that generated this record."""
20+ """The identifier of the job run that generated this historical record."""
2221
2322 object_type : str
24- """The inventory table for which this record was generated."""
23+ """The inventory table for which this historical record was generated."""
2524
2625 object_id : list [str ]
27- """The type-specific identifier for this inventory record."""
26+ """The type-specific identifier for the corresponding inventory record."""
2827
2928 data : dict [str , str ]
3029 """Type-specific JSON-encoded data of the inventory record."""
@@ -39,7 +38,7 @@ class HistoricalRecord:
3938 """The UCX semantic version."""
4039
4140 snapshot_id : str | None = None
42- """An identifier that is unique to the records produced for a given snapshot."""
41+ """An identifier that is unique to the historical records produced for a given snapshot."""
4342
4443 object_type_version : int = 0
4544 """Versioning of inventory table, for forward compatibility."""
@@ -57,5 +56,5 @@ def __init__(self, sql_backend: SqlBackend, ucx_catalog: str) -> None:
5756 def run (self ) -> None :
5857 self ._schema_deployer .deploy_schema ()
5958 self ._schema_deployer .deploy_table ("workflow_runs" , WorkflowRun )
60- self ._schema_deployer .deploy_table ("historical_records " , HistoricalRecord )
59+ self ._schema_deployer .deploy_table ("historical " , Historical )
6160 logger .info ("Installation completed successfully!" )
0 commit comments