How-to guide for Atlassian Jira notifications

Introduction

The Atlassian Jira notifier (airflow.providers.atlassian.jira.notifications.jira.JiraNotifier) allows users to create issues in a Jira instance using the various on_*_callbacks available at both the DAG level and Task level

Example Code

from datetime import datetime
from airflow import DAG
from airflow.providers.standard.operators.bash import BashOperator
from airflow.providers.atlassian.jira.notifications.jira import send_jira_notification

with DAG(
    "test-dag",
    start_date=datetime(2023, 11, 3),
    on_failure_callback=[
        send_jira_notification(
            jira_conn_id="my-jira-conn",
            description="Failure in the DAG {{ dag.dag_id }}",
            summary="Airflow DAG Issue",
            project_id=10000,
            issue_type_id=10003,
            labels=["airflow-dag-failure"],
        )
    ],
):
    BashOperator(
        task_id="mytask",
        on_failure_callback=[
            send_jira_notification(
                jira_conn_id="my-jira-conn",
                description="The task {{ ti.task_id }} failed",
                summary="Airflow Task Issue",
                project_id=10000,
                issue_type_id=10003,
                labels=["airflow-task-failure"],
            )
        ],
        bash_command="fail",
        retries=0,
    )

Was this entry helpful?