airflow_dag_jira_issue_creation_with_jira_operator.py

1import os
2from datetime import datetime
3
4from airflow import DAG
5from airflow.providers.atlassian.jira.operators.jira import JiraOperator
6
7# Note: This example assumes you have a Jira connection configured in Airflow 
8# with the connection ID 'jira_default'.
9
10with DAG(
11    dag_id="example_atlassian_jira_operator",
12    start_date=datetime(2021, 1, 1),
13    schedule_interval=None,
14    catchup=False,
15) as dag:
16
17    # Create a new issue in a JIRA project
18    create_issue = JiraOperator(
19        task_id="create_issue",
20        jira_conn_id="jira_default",
21        method="issue_create",
22        jira_method_args={
23            "fields": {
24                "project": {"key": "PROJ"},
25                "summary": "New issue from Airflow",
26                "description": "This issue was created by an Airflow DAG.",
27                "issuetype": {"name": "Bug"},
28            }
29        },
30    )
31
32    create_issue