LivyHookAsync
Astronomer ProvidersHook for Apache Livy through the REST API using LivyHookAsync
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
livy_conn_idreference to a pre-defined Livy Connection.
extra_optionsAdditional option can be passed when creating a request. For example, run(json=obj) is passed as aiohttp.ClientSession().get(json=obj)
extra_headersA dictionary of headers passed to the HTTP request to livy.
Documentation
Hook for Apache Livy through the REST API using LivyHookAsync
See also
For more details refer to the Apache Livy API reference: Apache Livy API reference