Hi @CJOkpala, it looks like the error is happening because the table animal_settings_hie_dim already exists. To fix this, start by dropping the existing table:

DROP TABLE IF EXISTS aadp_dev.edwa_stream.animal_settings_hie_dim;

Next, update your DLT pipeline to use the @dlt.create_or_refresh_streaming_table decorator. This allows the pipeline to handle table recreation properly during full refreshes.

@dlt.create_or_refresh_streaming_table(name="animal_settings_hie_dim") def create_table(): return dlt.read_stream("source")

Once you've dropped the table and updated the pipeline, run a full refresh. This should recreate the table cleanly and resolve the issue.