Skip to content

Commit

Permalink
Add undocumented parameters to LivyOperator and LivyHook docs…
Browse files Browse the repository at this point in the history
…trings (#16542)
  • Loading branch information
pgagnon committed Jun 19, 2021
1 parent 3d8ba64 commit 83b23ad
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 1 deletion.
4 changes: 4 additions & 0 deletions airflow/providers/apache/livy/hooks/livy.py
Expand Up @@ -49,6 +49,10 @@ class LivyHook(HttpHook, LoggingMixin):
:param livy_conn_id: reference to a pre-defined Livy Connection.
:type livy_conn_id: str
:param extra_options: A dictionary of options passed to Livy.
:type extra_options: Dict[str, Any]
:param extra_headers: A dictionary of headers passed to the HTTP request to livy.
:type extra_headers: Dict[str, Any]
.. seealso::
For more details refer to the Apache Livy API reference:
Expand Down
5 changes: 4 additions & 1 deletion airflow/providers/apache/livy/operators/livy.py
Expand Up @@ -65,8 +65,11 @@ class LivyOperator(BaseOperator):
:type livy_conn_id: str
:param polling_interval: time in seconds between polling for job completion. Don't poll for values >=0
:type polling_interval: int
:type extra_options: A dictionary of options, where key is string and value
:param extra_options: A dictionary of options, where key is string and value
depends on the option that's being modified.
:type extra_options: Dict[str, Any]
:param extra_headers: A dictionary of headers passed to the HTTP request to livy.
:type extra_headers: Dict[str, Any]
"""

template_fields = ('spark_params',)
Expand Down

0 comments on commit 83b23ad

Please sign in to comment.