airflow.contrib.sensors.jira_sensor

Module Contents

class airflow.contrib.sensors.jira_sensor.JiraSensor(jira_conn_id='jira_default', method_name=None, method_params=None, result_processor=None, *args, **kwargs)

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Monitors a jira ticket for any change.

Parameters

• jira_conn_id (str) – reference to a pre-defined Jira Connection

• method_name (str) – method name from jira-python-sdk to be execute

• method_params (dict) – parameters for the method method_name

• result_processor (function) – function that return boolean and act as a sensor response

poke(self, context)

class airflow.contrib.sensors.jira_sensor.JiraTicketSensor(jira_conn_id='jira_default', ticket_id=None, field=None, expected_value=None, field_checker_func=None, *args, **kwargs)

Bases: airflow.contrib.sensors.jira_sensor.JiraSensor

Monitors a jira ticket for given change in terms of function.

Parameters

• jira_conn_id (str) – reference to a pre-defined Jira Connection

• ticket_id (str) – id of the ticket to be monitored

• field (str) – field of the ticket to be monitored

• expected_value (str) – expected value of the field

• result_processor (function) – function that return boolean and act as a sensor response

template_fields = ['ticket_id']

poke(self, context)

issue_field_checker(self, context, issue)