Skip to content

Instantly share code, notes, and snippets.

@Kamparia

Kamparia/airflow_usgs_task_four.py Secret

Created December 15, 2020 08:05
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save Kamparia/98b9994a76bc174cec5c2e33003aef9c to your computer and use it in GitHub Desktop.
Save Kamparia/98b9994a76bc174cec5c2e33003aef9c to your computer and use it in GitHub Desktop.
Download ZIP
Task 4: Send Slack notifications to team members.
Raw
airflow_usgs_task_four.py
# Task 4: Send Slack notifications to Slack Channel.
task_four = SlackWebhookOperator(
task_id = 'send_slack_notification',
http_conn_id = 'slack_conn',
webhook_token = Variable.get("SLACK_API_TOKEN"),
message = "New earthquake events was successfully harvested.",
username = 'airflow'
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment