airflow.providers.atlassian.jira.sensors.jira

Module Contents

Classes

JiraSensor

Monitors a jira ticket for any change.

JiraTicketSensor

Monitors a jira ticket for given change in terms of function.
class airflow.providers.atlassian.jira.sensors.jira.JiraSensor(*, method_name, jira_conn_id='jira_default', method_params=None, result_processor=None, **kwargs)[source]

Bases: airflow.sensors.base.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 atlassian-python-api JIRA sdk to execute

  • method_params (dict | None) – parameters for the method method_name

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

poke(context)[source]

Override when deriving this class.

class airflow.providers.atlassian.jira.sensors.jira.JiraTicketSensor(*, jira_conn_id='jira_default', ticket_id=None, field=None, expected_value=None, field_checker_func=None, **kwargs)[source]

Bases: 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 | None) – id of the ticket to be monitored

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

  • expected_value (str | None) – expected value of the field

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

template_fields: Sequence[str] = ('ticket_id',)[source]
poke(context)[source]

Override when deriving this class.

issue_field_checker(jira_result)[source]

Check issue using different conditions to prepare to evaluate sensor.

Was this entry helpful?