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)[source]

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)[source]
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)[source]

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'][source]
poke(self, context)[source]
issue_field_checker(self, context, issue)[source]

Was this entry helpful?