I am working on DBT , we have requirement where I need to handle batch and CDC(change data capture) changes.
In this case input json messages are different in case of batch and CDC. So I need to write parsing logic differently for batch and CDC based on change type received from source.
If change type = ‘CREATE’
Call batch dbt models(7 models in my case)
If change type = ‘UPDATE’
Call incremental batch models(7 models in my case)
How to do we handle this flow in DBT?