@xj2193  I am not sure why you are getting this error, maybe if you could share some code to understand it.

Also, you could consider to use `create_auto_cdc_from_snapshot_flow` 

dlt.create_streaming_table("target")

dlt.create_auto_cdc_from_snapshot_flow(
 target="target",
 source="source",
 keys=["key"],
 stored_as_scd_type=2
)

https://docs.databricks.com/gcp/en/dlt-ref/dlt-python-ref-apply-changes-from-snapshot