:py:mod:`astronomer.providers.http.triggers.http` ================================================= .. py:module:: astronomer.providers.http.triggers.http Module Contents --------------- Classes ~~~~~~~ .. autoapisummary:: astronomer.providers.http.triggers.http.HttpTrigger .. py:class:: HttpTrigger(endpoint, http_conn_id = 'http_default', method = 'GET', data = None, headers = None, extra_options = None, poke_interval = 5.0) Bases: :py:obj:`airflow.triggers.base.BaseTrigger` A trigger that fires when the request to a URL returns a non-404 status code :param endpoint: The relative part of the full url :param http_conn_id: The HTTP Connection ID to run the sensor against :param method: The HTTP request method to use :param data: payload to be uploaded or aiohttp parameters :param headers: The HTTP headers to be added to the GET request :type headers: a dictionary of string key/value pairs :param extra_options: Additional kwargs to pass when creating a request. For example, ``run(json=obj)`` is passed as ``aiohttp.ClientSession().get(json=obj)`` :param poke_interval: Time to sleep using asyncio .. py:method:: serialize() Serializes HttpTrigger arguments and classpath. .. py:method:: run() :async: Makes a series of asynchronous http calls via an http hook. It yields a Trigger if response is a 200 and run_state is successful, will retry the call up to the retry limit if the error is 'retryable', otherwise it throws an exception.