@Dlt.table(
name=table_name,
comment="just_testing",
table_properties={
"quality": "gold",
"mergeSchema": "true"
},
cluster_by=["test_id", "find_date"] # Optimizes for queries filtering on these columns
)
def testing_table():
return create_testing_table(df_final, test_type)