airflow_dag_jira_operator_create_issue_example.py

1import os
2from datetime import datetime
3
4from airflow import DAG
5from airflow.providers.atlassian.jira.operators.jira import JiraOperator
6
7# Default arguments for the DAG
8default_args = {
9    'owner': 'airflow',
10    'start_date': datetime(2023, 1, 1),
11}
12
13with DAG(
14    dag_id='example_atlassian_jira_operator',
15    default_args=default_args,
16    schedule_interval=None,
17    catchup=False,
18    tags=['example', 'jira'],
19) as dag:
20
21    # Example of creating a new issue in JIRA
22    create_issue = JiraOperator(
23        task_id='create_issue',
24        jira_method='issue_create',
25        jira_method_args={
26            'fields': {
27                'project': {'key': 'PROJ'},
28                'summary': 'New issue from Airflow',
29                'description': 'Description of the issue created by Airflow JiraOperator',
30                'issuetype': {'name': 'Task'},
31            }
32        },
33    )
34
35    create_issue