CJOkpala
New Contributor II
Thanks for your response. But we did not find any documentation for @dlt.create_or_refresh_streaming_table decorator.
 
However we create many tables dynamically using dlt.create_streaming_table(name=table_name) which I doubt would be supported by the decorator.
 
Surely we tried dropping the tables first. But if we drop the table and run the pipeline again, we receive another error:
java.lang.IllegalStateException: Soft-deleted MV/STs that require changes cannot be undropped directly. If you need to update the target schema of the pipeline or modify the visibility of an MV/ST while also undropping it, please invoke the undrop operation with the original schema and visibility in an update first, before applying the changes in a subsequent update.
 
Hope you can help us further.