airflow.providers.jira.sensors.jira

Module Contents

class airflow.providers.jira.sensors.jira.JiraSensor(*, method_name: str, jira_conn_id: str = 'jira_default', method_params: Optional[dict] = None, result_processor: Optional[Callable] = 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 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: Dict)[source]
class airflow.providers.jira.sensors.jira.JiraTicketSensor(*, jira_conn_id: str = 'jira_default', ticket_id: Optional[str] = None, field: Optional[str] = None, expected_value: Optional[str] = None, field_checker_func: Optional[Callable] = None, **kwargs)[source]

Bases: airflow.providers.jira.sensors.jira.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: Dict)[source]
issue_field_checker(self, issue: Issue)[source]

Check issue using different conditions to prepare to evaluate sensor.

Was this entry helpful?