I didn't understand how do you change the schema dynamically, do you change the code and redeploy you are add the new function with using some command line tool or ?
I think in this case the cloud function that is invoked by the pubsub topic dynamically reinserts the failed write into the BQ instance without changing the pipeline. It doesn't really make sense given that they will then miss out on the other stages on their pipeline.
