В stg_marketing_api в поле additional_data приезжает какой-то мусор, а должен приезжать обязательно json

необходимо в даг, который на ods уровне считает че то(учитывая что в additional_data json), добавить проверку, является ли поле json форматом или нет
если не является -> не считаем по нему
является -> отрабатывает скрипт, как и раньше
Проблемный пайплайн: https://github.com/profcomff/dwh-pipelines/blob/main/dags/ods/marketing/printer_bots_actions.sql
По завершению - пингануть @VladislavVoskoboinik, удалим мусор из бд
В stg_marketing_api в поле additional_data приезжает какой-то мусор, а должен приезжать обязательно json
необходимо в даг, который на ods уровне считает че то(учитывая что в additional_data json), добавить проверку, является ли поле json форматом или нет
если не является -> не считаем по нему
является -> отрабатывает скрипт, как и раньше
Проблемный пайплайн: https://github.com/profcomff/dwh-pipelines/blob/main/dags/ods/marketing/printer_bots_actions.sql
По завершению - пингануть @VladislavVoskoboinik, удалим мусор из бд