Можно ли отложить подтверждение до тех пор, пока подграф (все, что ниже PubSubIO.Read) не будет успешно обработан?

Например, мыпотоковый читает из подписки на google pubsub, а затем записывает файл в GCS, а в другой ветке мы пишем в BigQuery, используя BigQueryIO.Write ...

Мы видим, что в случае возникновения исключения оно будет повторяться бесконечно, поскольку мы находимся в потоковом режиме. Однако если мы отменим задание и повторно развернем его с изменением кода, сообщение не будет повторно обработано.