fix(managed-backfills): Add clarity to slack notifications (#2091)

* fix(managed-backfills): Add clarity to slack notifications

* Update dags/bqetl_backfill_complete.py

Co-authored-by: Alexander <anicholson@mozilla.com>

---------

Co-authored-by: Alexander <anicholson@mozilla.com>
This commit is contained in:
Winnie Chan 2024-09-17 13:31:30 -07:00 коммит произвёл GitHub
Родитель 3f5e4fd541
Коммит e153811500
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: B5690EEEBB952194
2 изменённых файлов: 2 добавлений и 2 удалений

Просмотреть файл

@ -49,7 +49,7 @@ with DAG(
watcher_text = " ".join(
f"<@{watcher.split('@')[0]}>" for watcher in entry["watchers"]
)
return f"{watcher_text} :hourglass_flowing_sand: Completing backfill of `{entry['qualified_table_name']}`. A snapshot of the current production data will be kept as a backup."
return f"{watcher_text} :hourglass_flowing_sand: Completing backfill of `{entry['qualified_table_name']}` has started - currently swapping backfill data into production. A snapshot of the current production data will be kept as a backup. You will receive another notification once the completing step is done."
notify_initiate = SlackAPIPostOperator(
task_id="slack_notify_initate",

Просмотреть файл

@ -49,7 +49,7 @@ with DAG(
watcher_text = " ".join(
f"<@{watcher.split('@')[0]}>" for watcher in entry["watchers"]
)
return f"{watcher_text} :hourglass_flowing_sand: Initiating backfill scheduled for `{entry['qualified_table_name']}`."
return f"{watcher_text} :hourglass_flowing_sand: Initiating backfill scheduled for `{entry['qualified_table_name']}`. You will receive another notification once the backfill is done."
notify_initiate = SlackAPIPostOperator(
task_id="slack_notify_initate",