[Airflow > Slack message] Creation of DAG that notifies Slack channel #Airflow

airflow_slack_messaging.py

slack_message = "Home & Work for bundleId {} is ready for shipping!".format("{{ ti.xcom_pull(task_ids='get_bundle_id') }}")
notify_slack = SimpleHttpOperator(
    task_id="notify_slack",
    endpoint=slack_webhook_url,
    data=json.dumps(
        {"attachments": [{"fallback": slack_message, "text": slack_message, "color": "good"}]}),
    headers={"Content-Type": "application/json"},
    depends_on_past=False,
    response_check=lambda response: True if response.status_code == 200 else False,
    http_conn_id="http_slack_hook"
)