ExternalDeploymentTaskSensorAsync

Astronomer Providers

External deployment task sensor Make HTTP call and poll for the response state of externally deployed DAG task to complete. Inherits from HttpSensorAsync, the host should be external deployment url, header with access token

Access Instructions

Install the Astronomer Providers provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

http_conn_idThe Connection ID to run the sensor against
methodThe HTTP request method to use
endpointThe relative part of the full url
request_paramsThe parameters to be added to the GET url
headersThe HTTP headers to be added to the GET request
extra_optionsExtra options for the ‘requests’ library, see the ‘requests’ documentation (options to modify timeout, ssl, etc.)
tcp_keep_aliveEnable TCP Keep Alive for the connection.
tcp_keep_alive_idleThe TCP Keep Alive Idle parameter (corresponds to socket.TCP_KEEPIDLE).
tcp_keep_alive_countThe TCP Keep Alive count parameter (corresponds to socket.TCP_KEEPCNT)
tcp_keep_alive_intervalThe TCP Keep Alive interval parameter (corresponds to socket.TCP_KEEPINTVL)
poke_intervalTime in seconds that the job should wait in between each tries

Documentation

External deployment task sensor Make HTTP call and poll for the response state of externally deployed DAG task to complete. Inherits from HttpSensorAsync, the host should be external deployment url, header with access token

Was this page helpful?