| Search.setIndex({"docnames": ["_api/airflow/providers/apache/livy/hooks/index", "_api/airflow/providers/apache/livy/hooks/livy/index", "_api/airflow/providers/apache/livy/index", "_api/airflow/providers/apache/livy/operators/index", "_api/airflow/providers/apache/livy/operators/livy/index", "_api/airflow/providers/apache/livy/sensors/index", "_api/airflow/providers/apache/livy/sensors/livy/index", "_api/airflow/providers/apache/livy/triggers/index", "_api/airflow/providers/apache/livy/triggers/livy/index", "_api/tests/system/providers/apache/livy/example_livy/index", "_api/tests/system/providers/apache/livy/index", "changelog", "commits", "connections", "index", "installing-providers-from-sources", "operators", "security"], "filenames": ["_api/airflow/providers/apache/livy/hooks/index.rst", "_api/airflow/providers/apache/livy/hooks/livy/index.rst", "_api/airflow/providers/apache/livy/index.rst", "_api/airflow/providers/apache/livy/operators/index.rst", "_api/airflow/providers/apache/livy/operators/livy/index.rst", "_api/airflow/providers/apache/livy/sensors/index.rst", "_api/airflow/providers/apache/livy/sensors/livy/index.rst", "_api/airflow/providers/apache/livy/triggers/index.rst", "_api/airflow/providers/apache/livy/triggers/livy/index.rst", "_api/tests/system/providers/apache/livy/example_livy/index.rst", "_api/tests/system/providers/apache/livy/index.rst", "changelog.rst", "commits.rst", "connections.rst", "index.rst", "installing-providers-from-sources.rst", "operators.rst", "security.rst"], "titles": ["<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy.hooks</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy.hooks.livy</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy.operators</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy.operators.livy</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy.sensors</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy.sensors.livy</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy.triggers</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.livy.triggers.livy</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.apache.livy.example_livy</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.apache.livy</span></code>", "Changelog", "Package apache-airflow-providers-apache-livy", "Apache Livy Connection", "<code class=\"docutils literal notranslate\"><span class=\"pre\">apache-airflow-providers-apache-livy</span></code>", "Installing from sources", "Apache Livy Operators", "Releasing security patches"], "terms": {"3": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17], "8": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17], "0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17], "2": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16, 17], "10": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17], "dev0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17], "thi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17], "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17], "an": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17], "experiment": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17], "featur": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12, 13, 14, 15, 16, 17], "contain": [1, 4, 6, 8, 15], "batchstat": 1, "sourc": [1, 2, 4, 6, 8, 9, 16], "base": [1, 4, 6, 8], "enum": 1, "batch": [1, 4, 6, 8, 12, 16], "session": [1, 4, 6, 8, 11, 12], "state": [1, 8, 12], "not_start": 1, "start": 1, "run": [1, 4, 8, 11, 15, 16], "idl": 1, "busi": 1, "shutting_down": 1, "error": [1, 12], "dead": 1, "kill": [1, 4], "success": [1, 4, 8], "livyhook": [1, 4, 6, 11, 12], "livy_conn_id": [1, 4, 6, 8, 13], "default_conn_nam": 1, "extra_opt": [1, 4, 6, 8, 11, 12], "none": [1, 4, 6, 8, 15], "extra_head": [1, 4, 8, 12], "auth_typ": [1, 11, 12], "http": [1, 4, 8, 11, 12, 13, 14, 15], "httphook": 1, "util": [1, 16], "log": [1, 11, 12], "logging_mixin": 1, "loggingmixin": 1, "through": 1, "rest": [1, 4, 12, 16], "api": [1, 4, 11, 12, 16], "paramet": [1, 4, 6, 8, 11, 12, 13, 16], "str": [1, 4, 6, 8, 11, 12], "refer": [1, 4, 6, 8], "pre": [1, 4, 6, 8, 12], "defin": [1, 4, 6, 8], "connect": [1, 4, 6, 8, 11, 12], "dict": [1, 4, 8], "ani": [1, 4, 8, 15], "A": [1, 4, 8], "dictionari": [1, 4, 8], "option": [1, 4, 6, 8, 13], "pass": [1, 4, 8], "header": [1, 4, 8, 11, 12, 13], "request": [1, 4, 8, 11, 12], "The": [1, 4, 9, 13, 14, 15, 17], "auth": [1, 4, 11, 12], "type": [1, 4, 6, 11, 12, 13], "servic": [1, 13, 16], "For": [1, 12, 13, 14, 15, 16], "more": [1, 4, 12], "detail": [1, 12, 15], "org": [1, 8, 15, 16], "doc": [1, 11, 12], "latest": [1, 12, 17], "html": 1, "terminal_st": 1, "conn_name_attr": 1, "livy_default": [1, 4, 6, 8, 13], "conn_typ": 1, "hook_nam": 1, "get_conn": 1, "return": [1, 4, 6, 8], "us": [1, 4, 9, 12, 13, 14, 15, 17], "addit": 1, "run_method": 1, "endpoint": 1, "method": [1, 4], "get": [1, 4, 6, 15, 17], "data": [1, 12], "retry_arg": [1, 4, 11, 12], "wrap": [1, 4, 16], "allow": [1, 4, 16], "chang": [1, 12, 17], "same": [1, 4], "payload": 1, "argument": [1, 4, 8, 12], "which": [1, 4, 9, 17], "retri": [1, 4, 11, 12], "behaviour": [1, 4], "see": [1, 4, 12, 14], "tenac": [1, 4], "document": [1, 4, 11, 12], "github": [1, 4], "com": [1, 4, 13, 15], "jd": [1, 4], "respons": [1, 8], "post_batch": [1, 11, 12], "arg": [1, 4, 8, 12], "kwarg": [1, 4, 6], "perform": 1, "submit": [1, 4, 8, 16], "id": [1, 4, 8, 15], "int": [1, 4, 6, 8], "get_batch": 1, "session_id": [1, 11, 12], "fetch": [1, 11, 12], "info": [1, 12], "about": [1, 12, 15, 17], "specifi": [1, 13, 14], "identifi": [1, 6], "bodi": 1, "get_batch_st": 1, "delete_batch": 1, "delet": [1, 4], "get_batch_log": 1, "log_start_posit": 1, "log_batch_s": 1, "posit": 1, "from": [1, 12, 14, 17], "where": [1, 4, 8, 17], "pull": 1, "number": [1, 4, 12], "line": [1, 4, 12], "one": [1, 15], "dump_batch_log": 1, "dump": 1, "static": 1, "build_post_batch_bodi": 1, "file": [1, 4, 8, 11, 12, 15, 16], "class_nam": [1, 4, 8, 16], "jar": [1, 4, 8, 16], "py_fil": [1, 4], "archiv": [1, 4], "name": [1, 4, 12], "driver_memori": [1, 4], "driver_cor": [1, 4, 8], "executor_memori": [1, 4], "executor_cor": [1, 4, 8], "num_executor": [1, 4, 8, 16], "queue": [1, 4], "proxy_us": [1, 4], "conf": [1, 4, 16], "build": [1, 12, 15], "post": 1, "inform": [1, 12, 16, 17], "format": [1, 11, 12, 13], "path": [1, 4], "applic": [1, 4, 16], "execut": [1, 4, 9, 11, 12], "requir": [1, 4, 11, 17], "user": [1, 4, 12, 15], "imperson": [1, 4], "when": [1, 4, 6, 11, 12, 13, 14, 17], "job": [1, 4, 8, 16], "java": [1, 4, 9], "spark": [1, 4, 8, 9, 11, 12, 16], "main": [1, 4, 15, 17], "string": [1, 4, 8, 12], "sequenc": [1, 4, 6, 12], "float": [1, 4], "command": [1, 4, 8, 12], "": [1, 4, 6, 8, 11, 12, 15], "list": [1, 12], "python": [1, 4, 9, 11, 12, 14, 15], "amount": [1, 4], "memori": [1, 4], "driver": [1, 4], "process": [1, 4], "core": [1, 4, 12], "per": [1, 4, 12], "executor": [1, 4], "each": [1, 4], "launch": [1, 4], "yarn": [1, 4], "configur": [1, 4], "properti": [1, 4], "livyasynchook": [1, 8], "httpasynchook": 1, "asynchron": [1, 8, 16], "async": [1, 8], "hook": [2, 4, 6, 8, 11, 12, 13], "oper": [2, 11, 12], "sensor": 2, "trigger": [2, 4, 9, 11, 12, 16], "__version__": [2, 12], "livyoper": [4, 9, 11, 12], "livy_conn_auth_typ": [4, 6], "polling_interv": [4, 8, 11, 12, 16], "deferr": [4, 11, 12, 16], "getboolean": 4, "default_deferr": [4, 11, 12], "fallback": 4, "fals": [4, 16], "model": [4, 17], "baseoper": 4, "underli": [4, 16], "cluster": [4, 16], "templat": [4, 11, 12], "time": [4, 8, 11, 12], "second": [4, 8], "between": [4, 8], "poll": [4, 8, 16], "complet": [4, 8, 11], "don": 4, "t": 4, "valu": [4, 8, 13], "kei": [4, 8, 15], "depend": [4, 6, 8, 12, 17], "being": [4, 6, 8], "modifi": [4, 6, 8], "bool": 4, "mode": [4, 11, 12, 16], "template_field": [4, 6, 12], "spark_param": [4, 8, 11, 12], "template_fields_render": 4, "valid": [4, 6, 15], "get_hook": [4, 6], "context": [4, 6, 16], "deriv": [4, 6], "creat": [4, 8, 15], "render": [4, 11, 12], "jinja": 4, "get_template_context": 4, "poll_for_termin": [4, 8], "batch_id": [4, 6, 8], "pool": [4, 8], "termin": [4, 6, 8], "monitor": [4, 6, 8], "on_kil": 4, "overrid": [4, 6], "clean": 4, "up": [4, 12], "subprocess": 4, "task": [4, 9], "instanc": [4, 9], "thread": 4, "multiprocess": 4, "within": 4, "need": [4, 14, 16], "leav": 4, "ghost": 4, "behind": 4, "current": 4, "execute_complet": 4, "event": 4, "fire": 4, "immedi": [4, 8], "reli": 4, "throw": 4, "except": [4, 11, 12, 17], "otherwis": [4, 8, 11], "assum": 4, "wa": 4, "livysensor": 6, "basesensoroper": 6, "poke": 6, "livytrigg": 8, "livy_hook_async": 8, "execution_timeout": 8, "basetrigg": 8, "check": [8, 11, 12, 15], "previous": 8, "exampl": [8, 9, 12, 13, 14, 15, 16], "test": [8, 16, 17], "pi": [8, 9, 16], "py": [8, 11, 12, 16], "sparkpi": [8, 16], "usr": 8, "lib": 8, "bin": [8, 15], "runner": 8, "1": [8, 16], "4": 8, "If": [8, 11, 15], "poll_interv": 8, "case": [8, 13, 17], "interv": 8, "object": 8, "serial": 8, "classpath": 8, "_polling_interv": 8, "dag": [9, 12], "below": [9, 14, 15], "comput": 9, "librari": [9, 16], "env_id": 9, "dag_id": 9, "example_livy_oper": 9, "livy_java_task": [9, 16], "test_run": 9, "example_livi": [10, 16], "apach": [11, 15], "airflow": [11, 15, 16, 17], "provid": [11, 15, 16, 17], "livi": [11, 15], "releas": [11, 12, 14], "onli": [11, 12, 17], "avail": [11, 15, 16], "explain": 11, "support": [11, 12, 14], "polici": [11, 17], "its": [11, 12], "out": [11, 12, 17], "38916": [11, 12], "38979": [11, 12], "bump": [11, 12], "minimum": [11, 12, 14], "version": [11, 12, 14, 15, 17], "39240": [11, 12], "updat": [11, 12], "docstr": [11, 12], "39266": [11, 12], "37361": [11, 12], "aiohttp": [11, 12, 14], "min": [11, 12], "avoid": [11, 12], "cve": [11, 12], "2024": [11, 12], "23829": [11, 12], "23334": [11, 12], "37110": [11, 12], "assign": 11, "field": [11, 12, 13], "__init__": [11, 12], "36490": [11, 12], "36017": [11, 12], "34728": [11, 12], "consolid": [11, 12], "manag": [11, 12, 15, 16], "34431": [11, 12], "refactor": [11, 12], "regex": [11, 12], "33898": [11, 12], "improv": [11, 12], "modul": [11, 12], "import": [11, 12, 15], "some": [11, 12], "them": [11, 12, 14], "block": [11, 12], "33754": [11, 12], "remov": [11, 12, 15], "useless": [11, 12], "call": [11, 12], "33629": [11, 12], "simplifi": [11, 12], "code": [11, 12, 15, 16], "alibaba": [11, 12], "33227": [11, 12], "condit": [11, 12], "len": [11, 12], "33564": [11, 12], "typeerror": [11, 12], "32051": [11, 12], "add": [11, 12, 13], "config": [11, 12], "31712": [11, 12], "drop": [11, 12, 15], "push": [11, 12], "appid": [11, 12], "xcom": [11, 12], "31201": [11, 12], "optim": [11, 12], "defer": [11, 12], "31685": [11, 12], "30917": [11, 12], "non": [11, 12], "login": [11, 12, 13], "password": [11, 12, 13], "simplehttpop": [11, 12], "29206": [11, 12], "29047": [11, 12], "move": [11, 12], "all": [11, 12, 13, 14, 16, 17], "27196": [11, 12], "27404": [11, 12], "output": [11, 12], "27376": [11, 12], "27321": [11, 12], "25183": [11, 12], "extra": [11, 12, 13, 14], "instead": [11, 12], "22510": [11, 12], "mistakenli": 11, "ad": [11, 12], "install_requir": 11, "22382": 11, "trove": 11, "classifi": [11, 12], "pypi": [11, 12, 14, 17], "framework": 11, "19384": [11, 12], "21550": [11, 12], "how": [11, 12, 15], "guid": [11, 12, 15], "21529": [11, 12], "livyoperr": [11, 12], "17393": [11, 12], "optimis": 11, "auto": [11, 12], "appli": [11, 12], "apply_default": [11, 12], "decor": [11, 12], "15667": [11, 12], "due": 11, "your": [11, 16], "you": [11, 13, 14, 15, 16, 17], "want": [11, 15, 17], "instal": [11, 12, 17], "first": 11, "upgrad": [11, 12, 17], "least": 11, "packag": 11, "automat": 11, "have": [11, 12, 17], "manual": 11, "db": 11, "migrat": [11, 12], "extend": [11, 12], "14816": [11, 12], "readm": [11, 12], "initi": 11, "commit": 12, "high": 12, "level": 12, "changelog": 12, "includ": [12, 14, 17], "04": 12, "27": 12, "subject": 12, "04caa6eceb": 12, "ead9b00f7c": 12, "25": 12, "bf5ab8fc46": 12, "14": 12, "fix": [12, 17], "bug": [12, 17], "6de420a0e": 12, "13": 12, "5fa80b6aea": 12, "prepar": [12, 17], "1st": 12, "wave": 12, "rc1": 12, "april": 12, "38863": 12, "0a74928894": 12, "03": 12, "18": 12, "ruff": 12, "38240": 12, "83316b8158": 12, "march": 12, "37876": 12, "5a0be392e6": 12, "02": 12, "16": 12, "comment": 12, "37488": 12, "82d9a89611": 12, "12": [12, 15], "bfb054e9e8": 12, "februari": 12, "37326": 12, "0c4210af62": 12, "01": 12, "31": 12, "07": 12, "19ebcac239": 12, "januari": 12, "36640": 12, "6937ae7647": 12, "2023": 12, "30": 12, "speed": 12, "autocomplet": 12, "breez": 12, "36499": 12, "eac3d95584": 12, "29": 12, "unnecessari": 12, "9b5d6bfe27": 12, "28": 12, "3rd": 12, "deember": 12, "36464": 12, "b15d5578da": 12, "23": 12, "re": 12, "2nd": 12, "decemb": 12, "36380": 12, "08": 12, "999b70178a": 12, "36112": 12, "d0918d77ee": 12, "0b23d5601c": 12, "11": [12, 15], "24": 12, "novemb": 12, "35836": 12, "99534e47f3": 12, "19": 12, "reproduc": 12, "35693": 12, "99df205f42": 12, "reappli": 12, "35686": 12, "1b059c57d6": 12, "35537": 12, "d1c58d86de": 12, "octob": 12, "35233": 12, "3592ff4046": 12, "35187": 12, "dd7ba3cae1": 12, "292": 12, "35053": 12, "e9987d5059": 12, "34916": 12, "0c8e30e43b": 12, "05": 12, "99f320354b": 12, "34402": 12, "c95aa7863f": 12, "09": 12, "21990ed894": 12, "34201": 12, "a7310f9c91": 12, "9d8c77e447": 12, "26": 12, "c077d19060": 12, "aug": 12, "33730": 12, "85acbb4ae9": 12, "32feab4100": 12, "22": 12, "af0a4a0698": 12, "21": 12, "c645d8e40c": 12, "d401": 12, "airbyt": 12, "atlassian": 12, "inclus": 12, "33354": 12, "06": 12, "225e3041d2": 12, "juli": 12, "rc2": 12, "32381": 12, "3878fe6fab": 12, "spuriou": 12, "32373": 12, "cb4927a018": 12, "32298": 12, "f8593503cb": 12, "8c37b74a20": 12, "d205": 12, "common": 12, "32226": 12, "09d4718d3a": 12, "structur": 12, "32125": 12, "58784ade88": 12, "20": 12, "79bcc2e668": 12, "june": 12, "32001": 12, "8b146152d6": 12, "note": [12, 13, 16], "32015": 12, "13890788ae": 12, "31730": 12, "361aa77d5d": 12, "dc5bf3fd02": 12, "discover": 12, "yaml": 12, "31576": 12, "a473facf6c": 12, "d400": 12, "pydocstyl": 12, "31424": 12, "bfb14f6ffa": 12, "45548b9451": 12, "mai": [12, 13], "31416": 12, "abea189022": 12, "31393": 12, "f5aed58d9f": 12, "circular": 12, "caus": 12, "31379": 12, "d9ff55cf6d": 12, "31252": 12, "eef5bc7f16": 12, "full": 12, "autom": 12, "30994": 12, "a7eb32a5b2": 12, "9409446097": 12, "cli": 12, "cmd": 12, "30822": 12, "c585ad51c5": 12, "262": 12, "30809": 12, "d23a3bbed8": 12, "mechan": 12, "suspend": 12, "30422": 12, "55dbf1ff1f": 12, "30378": 12, "c44c7e1b48": 12, "c3867781e0": 12, "29950": 12, "fcd3c0149f": 12, "29878": 12, "47ebe99972": 12, "911b708ffd": 12, "jan": 12, "mid": 12, "month": 12, "28929": 12, "2b92c3c74d": 12, "28754": 12, "2022": 12, "15": 12, "12c3c39d1a": 12, "27613": 12, "7dd7400dd4": 12, "f75582a8eb": 12, "0c94eff950": 12, "9ab1a6a3e7": 12, "old": 12, "style": 12, "26872": 12, "78b8ea2f22": 12, "2a34dc9e84": 12, "enabl": [12, 13, 16], "normal": 12, "27205": 12, "f8db64c35c": 12, "septemb": 12, "26731": 12, "06acf40a43": 12, "pep": 12, "563": 12, "postpon": 12, "evalu": 12, "annot": 12, "26289": 12, "e5ac6c7cfb": 12, "new": [12, 17], "august": 12, "25618": 12, "7d3e799f7": 12, "d2459a241b": 12, "25030": 12, "0de31bd73a": 12, "insid": 12, "folder": [12, 15], "24672": 12, "510a6bab45": 12, "class": [12, 14], "24702": 12, "dcdcf3a2b8": 12, "24307": 12, "717a7588bc": 12, "descript": 12, "doubl": 12, "specif": 12, "24292": 12, "aeabe994b3": 12, "24231": 12, "027b707d21": 12, "explanatori": 12, "contributor": 12, "24229": 12, "5503603cde": 12, "aip": 12, "47": 12, "design": 12, "22439": 12, "24208": 12, "56ab82ed7a": 12, "22819": 12, "97cf76904a": 12, "d7dbfb7e26": 12, "bugfix": [12, 17], "22383": 12, "16adc035b1": 12, "22226": 12, "f5b96315fe": 12, "feb": 12, "22056": 12, "5fdd6fa479": 12, "c25534be56": 12, "d94fa37830": 12, "delai": 12, "21439": 12, "6c3a67d4fc": 12, "2021": [12, 15], "21257": 12, "602abe8394": 12, "now": 12, "sphinx": 12, "autoapi": 12, "typehint": 12, "20951": 12, "f77417eb0d": 12, "k8": 12, "compat": 12, "20614": 12, "97496ba2b4": 12, "20523": 12, "d56e7b56bb": 12, "mypi": 12, "friendli": 12, "20571": 12, "485ff6cc64": 12, "20422": 12, "853576d901": 12, "19882": 12, "ae044884d1": 12, "cleanup": 12, "start_dat": 12, "default": [12, 17], "18657": 12, "d9567eb106": 12, "19321": 12, "86a2a19ad2": 12, "17": 12, "f": 12, "18855": 12, "0a68588479": 12, "17890": 12, "be75dcd39c": 12, "meta": 12, "02a33b55d1": 12, "76ed2a49c6": 12, "lazili": 12, "individu": 12, "17682": 12, "87f408b1e7": 12, "17116": 12, "b916b75079": 12, "17015": 12, "866a601b76": 12, "pylint": 12, "our": 12, "toolchain": 12, "16682": 12, "83b23ad197": 12, "undocu": 12, "16542": 12, "3d8ba64b84": 12, "16512": 12, "bbc627a3da": 12, "16501": 12, "cbf8001d76": 12, "synchron": [12, 16], "after": 12, "buggfix": 12, "16464": 12, "1fba5402bb": 12, "16405": 12, "9c94b72d44": 12, "16294": 12, "37681bca00": 12, "042be2e4e0": 12, "befor": 12, "15236": 12, "68e4c4dcb0": 12, "backport": 12, "14886": 12, "70731073d0": 12, "6e6526a0f6": 12, "broken": 12, "14734": 12, "88bdcfa0df": 12, "14013": 12, "ac2f72c98d": 12, "implement": 12, "tool": 12, "13767": 12, "3fd5ef3555": 12, "miss": 12, "logo": 12, "integr": 12, "13717": 12, "295d66f914": 12, "2020": 12, "grammar": 12, "pip": [12, 14, 15], "warn": [12, 15], "13380": 12, "6cf76d7ac0": 12, "typo": 12, "13148": 12, "32971a1a2d": 12, "12955": 12, "b40dffa085": 12, "renam": 12, "rema": 12, "match": [12, 15], "12917": 12, "9b39f24780": 12, "dynam": 12, "form": 12, "12558": 12, "c34ef853c8": 12, "separ": [12, 17], "12444": 12, "0080354502": 12, "0b2": 12, "12449": 12, "ae7cb4a1e2": 12, "wrong": 12, "hash": 12, "12390": 12, "6889a333cf": 12, "ref": 12, "12366": 12, "7825e8f590": 12, "12304": 12, "85a18e13d9": 12, "point": 12, "project": 12, "page": [12, 15], "cross": 12, "12212": 12, "59eb5de78c": 12, "come": 12, "0beta1": 12, "12206": 12, "b2a28d1590": 12, "script": [12, 15], "dev": 12, "12082": 12, "4e8f9cc8d0": 12, "black": 12, "formmatt": 12, "9550": 12, "8c42cf1b00": 12, "pyupgrad": 12, "11447": 12, "5a439e84eb": 12, "2a1": 12, "11855": 12, "872b1566a1": 12, "gener": 12, "setup": 12, "11826": 12, "4830687453": 12, "super": 12, "11806": 12, "349b0811c3": 12, "d200": 12, "11688": 12, "16e7129719": 12, "11487": 12, "0a0e1af800": 12, "markdown": 12, "link": [12, 15], "toc": 12, "11249": 12, "ca4238eb4d": 12, "11242": 12, "5220e4c384": 12, "11238": 12, "9549274d11": 12, "8b1": 12, "10818": 12, "fdd9b6f65b": 12, "10543": 12, "3696c34c28": 12, "word": 12, "10528": 12, "ee7ca128a1": 12, "refernc": 12, "10483": 12, "3b3287d7ac": 12, "enforc": 12, "keyword": 12, "10170": 12, "7d24b088cd": 12, "stop": 12, "default_arg": 12, "example_dag": 12, "9985": 12, "33f0cd2657": 12, "keep": 12, "function": 12, "signatur": [12, 14, 15], "9784": 12, "4d74ac2111": 12, "increas": 12, "9729": 12, "d0e7db4024": 12, "fresh": 12, "9408": 12, "12af6a0800": 12, "final": 12, "23rc1": 12, "9404": 12, "c7e5bce57f": 12, "candid": 12, "9370": 12, "f6bd817a3a": 12, "introduc": 12, "transfer": 12, "9320": 12, "0b0e4f7a4c": 12, "rc3": 12, "relas": 12, "9026": 12, "00642a46d0": 12, "remain": 12, "wrongli": 12, "8994": 12, "375d1ca229": 12, "8898": 12, "12c5e5d8a": 12, "8891": 12, "f3521fb0e3": 12, "regener": 12, "8886": 12, "92585ca4cb": 12, "8807": 12, "3320e432a1": 12, "6817": 12, "lazi": 12, "load": 12, "face": 12, "untouch": 12, "7517": 12, "4d03e33c11": 12, "replac": 12, "implicit": 12, "explicit": 12, "entri": 12, "md": 12, "squash": 12, "rebas": 12, "7456": 12, "d3cf23dc07": 12, "5470": 12, "6090": 12, "under": 13, "hood": 13, "host": 13, "server": [13, 15], "scheme": 13, "give": 13, "schema": 13, "port": 13, "url": 13, "etc": 13, "would": 13, "like": 13, "too": 13, "json": 13, "environ": 13, "variabl": 13, "should": [13, 15, 17], "uri": 13, "syntax": 13, "compon": 13, "encod": 13, "export": 13, "airflow_conn_livy_default": 13, "usernam": 13, "80": 13, "ar": [14, 15, 17], "can": [14, 15, 16, 17], "top": [14, 15], "exist": 14, "via": [14, 15, 16], "7": 14, "9": 14, "asgiref": 14, "those": [14, 15], "might": [14, 17], "order": 14, "verifi": 14, "checksum": [14, 15], "site": 14, "sdist": [14, 15], "asc": [14, 15], "sha512": [14, 15], "wheel": 14, "describ": 15, "download": 15, "offici": 15, "also": [15, 16], "most": 15, "choos": 15, "differ": 15, "select": 15, "down": 15, "left": 15, "whl": 15, "origin": 15, "softwar": 15, "foundat": 15, "abov": 15, "pgp": 15, "It": [15, 16], "essenti": 15, "sha": 15, "gpg": 15, "pleas": 15, "well": [15, 16], "relev": 15, "distribut": 15, "recommend": 15, "directori": 15, "mirror": 15, "pgpk": 15, "ka": 15, "To": 15, "binari": 15, "follow": [15, 17], "pgpv": 15, "tar": 15, "gz": 15, "made": 15, "sat": 15, "sep": 15, "49": 15, "54": 15, "bst": 15, "rsa": 15, "cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f": 15, "issuer": 15, "kaxilnaik": 15, "good": [15, 17], "kaxil": 15, "naik": 15, "unknown": 15, "aka": 15, "gmail": 15, "certifi": 15, "trust": 15, "There": 15, "indic": 15, "belong": 15, "owner": 15, "primari": 15, "fingerprint": 15, "cde1": 15, "5c6e": 15, "4d3a": 15, "8ec4": 15, "ecf4": 15, "ba4b": 15, "6674": 15, "e08a": 15, "d7de": 15, "406f": 15, "correct": 15, "do": 15, "worri": 15, "certif": 15, "self": 15, "sign": 15, "why": 15, "By": 15, "previou": 15, "step": 15, "know": 15, "alreadi": 15, "sum": 15, "shasum": 15, "512": 15, "diff": 15, "local": 15, "bash": 15, "package_vers": 15, "package_nam": 15, "provider_download_dir": 15, "mktemp": 15, "d": 15, "dep": 15, "dest": 15, "curl": 15, "apache_airflow_providers_apache_livi": 15, "py3": 15, "l": 15, "o": 15, "echo": 15, "la": 15, "onc": 15, "instruct": [15, 17], "chapter": 15, "temporari": 15, "easi": 16, "interact": 16, "over": 16, "interfac": 16, "submiss": 16, "snippet": 16, "result": 16, "retriev": 16, "simpl": 16, "rpc": 16, "client": 16, "system": 16, "task_id": 16, "pi_java_task": 16, "shuffl": 16, "compress": 16, "livy_python_task": 16, "pi_python_task": 16, "60": 16, "set": 16, "true": 16, "lead": 16, "effici": 16, "worker": 16, "statu": 16, "happen": 16, "deploy": 16, "livy_java_task_deferr": 16, "livy_python_task_deferr": 16, "further": 16, "look": 16, "independ": 17, "itself": 17, "vulner": 17, "publish": 17, "found": 17, "we": 17, "develop": 17, "alwai": 17, "done": 17, "branch": 17, "next": 17, "strict": 17, "semver": 17, "scope": 17, "major": 17, "break": 17, "minor": 17, "patchlevel": 17, "receiv": 17, "so": 17, "rule": 17, "critic": 17, "reason": 17, "band": 17, "stakehold": 17, "decid": 17, "cherri": 17, "pick": 17, "older": 17, "mix": 17, "govern": 17, "interest": 17, "parti": 17}, "objects": {"airflow.providers.apache": [[2, 0, 0, "-", "livy"]], "airflow.providers.apache.livy": [[2, 1, 1, "", "__version__"], [0, 0, 0, "-", "hooks"], [3, 0, 0, "-", "operators"], [5, 0, 0, "-", "sensors"], [7, 0, 0, "-", "triggers"]], "airflow.providers.apache.livy.hooks": [[1, 0, 0, "-", "livy"]], "airflow.providers.apache.livy.hooks.livy": [[1, 2, 1, "", "BatchState"], [1, 2, 1, "", "LivyAsyncHook"], [1, 2, 1, "", "LivyHook"]], "airflow.providers.apache.livy.hooks.livy.BatchState": [[1, 3, 1, "", "BUSY"], [1, 3, 1, "", "DEAD"], [1, 3, 1, "", "ERROR"], [1, 3, 1, "", "IDLE"], [1, 3, 1, "", "KILLED"], [1, 3, 1, "", "NOT_STARTED"], [1, 3, 1, "", "RUNNING"], [1, 3, 1, "", "SHUTTING_DOWN"], [1, 3, 1, "", "STARTING"], [1, 3, 1, "", "SUCCESS"]], "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook": [[1, 3, 1, "", "TERMINAL_STATES"], [1, 4, 1, "", "build_post_batch_body"], [1, 3, 1, "", "conn_name_attr"], [1, 3, 1, "", "conn_type"], [1, 3, 1, "", "default_conn_name"], [1, 4, 1, "", "dump_batch_logs"], [1, 4, 1, "", "get_batch_logs"], [1, 4, 1, "", "get_batch_state"], [1, 3, 1, "", "hook_name"], [1, 4, 1, "", "run_method"]], "airflow.providers.apache.livy.hooks.livy.LivyHook": [[1, 3, 1, "", "TERMINAL_STATES"], [1, 4, 1, "", "build_post_batch_body"], [1, 3, 1, "", "conn_name_attr"], [1, 3, 1, "", "conn_type"], [1, 3, 1, "", "default_conn_name"], [1, 4, 1, "", "delete_batch"], [1, 4, 1, "", "dump_batch_logs"], [1, 4, 1, "", "get_batch"], [1, 4, 1, "", "get_batch_logs"], [1, 4, 1, "", "get_batch_state"], [1, 4, 1, "", "get_conn"], [1, 3, 1, "", "hook_name"], [1, 4, 1, "", "post_batch"], [1, 4, 1, "", "run_method"]], "airflow.providers.apache.livy.operators": [[4, 0, 0, "-", "livy"]], "airflow.providers.apache.livy.operators.livy": [[4, 2, 1, "", "LivyOperator"]], "airflow.providers.apache.livy.operators.livy.LivyOperator": [[4, 4, 1, "", "execute"], [4, 4, 1, "", "execute_complete"], [4, 4, 1, "", "get_hook"], [4, 4, 1, "", "hook"], [4, 4, 1, "", "kill"], [4, 4, 1, "", "on_kill"], [4, 4, 1, "", "poll_for_termination"], [4, 3, 1, "", "template_fields"], [4, 3, 1, "", "template_fields_renderers"]], "airflow.providers.apache.livy.sensors": [[6, 0, 0, "-", "livy"]], "airflow.providers.apache.livy.sensors.livy": [[6, 2, 1, "", "LivySensor"]], "airflow.providers.apache.livy.sensors.livy.LivySensor": [[6, 4, 1, "", "get_hook"], [6, 4, 1, "", "poke"], [6, 3, 1, "", "template_fields"]], "airflow.providers.apache.livy.triggers": [[8, 0, 0, "-", "livy"]], "airflow.providers.apache.livy.triggers.livy": [[8, 2, 1, "", "LivyTrigger"]], "airflow.providers.apache.livy.triggers.livy.LivyTrigger": [[8, 4, 1, "", "poll_for_termination"], [8, 4, 1, "", "run"], [8, 4, 1, "", "serialize"]], "tests.system.providers.apache": [[10, 0, 0, "-", "livy"]], "tests.system.providers.apache.livy": [[9, 0, 0, "-", "example_livy"]], "tests.system.providers.apache.livy.example_livy": [[9, 1, 1, "", "DAG_ID"], [9, 1, 1, "", "ENV_ID"], [9, 1, 1, "", "livy_java_task"], [9, 1, 1, "", "test_run"]]}, "objtypes": {"0": "py:module", "1": "py:data", "2": "py:class", "3": "py:attribute", "4": "py:method"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "data", "Python data"], "2": ["py", "class", "Python class"], "3": ["py", "attribute", "Python attribute"], "4": ["py", "method", "Python method"]}, "titleterms": {"airflow": [0, 1, 2, 3, 4, 5, 6, 7, 8, 12, 14], "provid": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12, 14], "apach": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12, 13, 14, 16], "livi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12, 13, 14, 16], "hook": [0, 1], "submodul": [0, 3, 5, 7, 10], "modul": [1, 4, 6, 8, 9], "content": [1, 2, 4, 6, 8, 9], "class": [1, 4, 6, 8], "subpackag": 2, "packag": [2, 12, 14, 15], "oper": [3, 4, 16], "sensor": [5, 6], "trigger": [7, 8], "test": [9, 10], "system": [9, 10], "example_livi": 9, "changelog": 11, "3": [11, 12], "8": [11, 12], "0": [11, 12], "bug": 11, "fix": 11, "misc": 11, "7": [11, 12], "2": [11, 12], "1": [11, 12], "6": [11, 12], "5": [11, 12], "4": [11, 12], "featur": 11, "break": 11, "chang": 11, "connect": 13, "default": 13, "id": 13, "configur": 13, "instal": [14, 15], "requir": 14, "cross": 14, "depend": 14, "download": 14, "offici": 14, "from": 15, "sourc": 15, "releas": [15, 17], "integr": 15, "verifi": 15, "pypi": 15, "livyoper": 16, "refer": 16, "secur": 17, "patch": 17}, "envversion": {"sphinx.domains.c": 2, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 8, "sphinx.domains.index": 1, "sphinx.domains.javascript": 2, "sphinx.domains.math": 2, "sphinx.domains.python": 3, "sphinx.domains.rst": 2, "sphinx.domains.std": 2, "sphinx.ext.viewcode": 1, "sphinx.ext.intersphinx": 1, "sphinx": 57}, "alltitles": {"airflow.providers.apache.livy.hooks": [[0, "module-airflow.providers.apache.livy.hooks"]], "Submodules": [[0, "submodules"], [3, "submodules"], [5, "submodules"], [7, "submodules"], [10, "submodules"]], "airflow.providers.apache.livy.hooks.livy": [[1, "module-airflow.providers.apache.livy.hooks.livy"]], "Module Contents": [[1, "module-contents"], [4, "module-contents"], [6, "module-contents"], [8, "module-contents"], [9, "module-contents"]], "Classes": [[1, "classes"], [4, "classes"], [6, "classes"], [8, "classes"]], "airflow.providers.apache.livy": [[2, "module-airflow.providers.apache.livy"]], "Subpackages": [[2, "subpackages"]], "Package Contents": [[2, "package-contents"]], "airflow.providers.apache.livy.operators": [[3, "module-airflow.providers.apache.livy.operators"]], "airflow.providers.apache.livy.operators.livy": [[4, "module-airflow.providers.apache.livy.operators.livy"]], "airflow.providers.apache.livy.sensors": [[5, "module-airflow.providers.apache.livy.sensors"]], "airflow.providers.apache.livy.sensors.livy": [[6, "module-airflow.providers.apache.livy.sensors.livy"]], "airflow.providers.apache.livy.triggers": [[7, "module-airflow.providers.apache.livy.triggers"]], "airflow.providers.apache.livy.triggers.livy": [[8, "module-airflow.providers.apache.livy.triggers.livy"]], "tests.system.providers.apache.livy.example_livy": [[9, "module-tests.system.providers.apache.livy.example_livy"]], "tests.system.providers.apache.livy": [[10, "module-tests.system.providers.apache.livy"]], "Changelog": [[11, "changelog"]], "3.8.0": [[11, "id1"], [12, "id1"]], "Bug Fixes": [[11, "bug-fixes"], [11, "id3"], [11, "id7"], [11, "id19"], [11, "id22"], [11, "id39"], [11, "id41"]], "Misc": [[11, "misc"], [11, "id5"], [11, "id10"], [11, "id13"], [11, "id15"], [11, "id17"], [11, "id20"], [11, "id23"], [11, "id26"], [11, "id32"], [11, "id43"], [11, "id46"], [11, "id49"]], "3.7.3": [[11, "id2"], [12, "id2"]], "3.7.2": [[11, "id4"], [12, "id3"]], "3.7.1": [[11, "id6"], [12, "id4"]], "3.7.0": [[11, "id8"], [12, "id5"]], "3.6.0": [[11, "id11"], [12, "id6"]], "3.5.4": [[11, "id14"], [12, "id7"]], "3.5.3": [[11, "id16"], [12, "id8"]], "3.5.2": [[11, "id18"], [12, "id9"]], "3.5.1": [[11, "id21"], [12, "id10"]], "3.5.0": [[11, "id24"], [12, "id11"]], "3.4.0": [[11, "id27"], [12, "id13"]], "Features": [[11, "features"], [11, "id29"], [11, "id33"], [11, "id35"], [11, "id45"], [11, "id48"], [11, "id53"]], "3.3.0": [[11, "id28"], [12, "id14"]], "3.2.0": [[11, "id30"], [12, "id15"]], "3.1.0": [[11, "id34"], [12, "id16"]], "3.0.0": [[11, "id36"], [12, "id17"]], "Breaking changes": [[11, "breaking-changes"], [11, "id51"]], "2.2.3": [[11, "id38"], [12, "id18"]], "2.2.2": [[11, "id40"], [12, "id19"]], "2.2.1": [[11, "id42"], [12, "id20"]], "2.2.0": [[11, "id44"], [12, "id21"]], "2.1.0": [[11, "id47"], [12, "id22"]], "2.0.0": [[11, "id50"], [12, "id23"]], "1.1.0": [[11, "id52"], [12, "id24"]], "1.0.1": [[11, "id54"], [12, "id25"]], "1.0.0": [[11, "id55"], [12, "id26"]], "Package apache-airflow-providers-apache-livy": [[12, "package-apache-airflow-providers-apache-livy"]], "Apache Livy Connection": [[13, "apache-livy-connection"]], "Default Connection IDs": [[13, "default-connection-ids"]], "Configuring the Connection": [[13, "configuring-the-connection"]], "apache-airflow-providers-apache-livy": [[14, "apache-airflow-providers-apache-livy"]], "apache-airflow-providers-apache-livy package": [[14, "apache-airflow-providers-apache-livy-package"]], "Provider package": [[14, "provider-package"]], "Installation": [[14, "installation"]], "Requirements": [[14, "requirements"]], "Cross provider package dependencies": [[14, "cross-provider-package-dependencies"]], "Downloading official packages": [[14, "downloading-official-packages"]], "Installing from sources": [[15, "installing-from-sources"]], "Released packages": [[15, "released-packages"]], "Release integrity": [[15, "release-integrity"]], "Verifying PyPI releases": [[15, "verifying-pypi-releases"]], "Apache Livy Operators": [[16, "apache-livy-operators"]], "LivyOperator": [[16, "livyoperator"]], "Reference": [[16, "reference"]], "Releasing security patches": [[17, "releasing-security-patches"]]}, "indexentries": {"airflow.providers.apache.livy.hooks": [[0, "module-airflow.providers.apache.livy.hooks"]], "module": [[0, "module-airflow.providers.apache.livy.hooks"], [1, "module-airflow.providers.apache.livy.hooks.livy"], [2, "module-airflow.providers.apache.livy"], [3, "module-airflow.providers.apache.livy.operators"], [4, "module-airflow.providers.apache.livy.operators.livy"], [5, "module-airflow.providers.apache.livy.sensors"], [6, "module-airflow.providers.apache.livy.sensors.livy"], [7, "module-airflow.providers.apache.livy.triggers"], [8, "module-airflow.providers.apache.livy.triggers.livy"], [9, "module-tests.system.providers.apache.livy.example_livy"], [10, "module-tests.system.providers.apache.livy"]], "busy (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.BUSY"]], "batchstate (class in airflow.providers.apache.livy.hooks.livy)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState"]], "dead (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.DEAD"]], "error (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.ERROR"]], "idle (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.IDLE"]], "killed (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.KILLED"]], "livyasynchook (class in airflow.providers.apache.livy.hooks.livy)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook"]], "livyhook (class in airflow.providers.apache.livy.hooks.livy)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook"]], "not_started (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.NOT_STARTED"]], "running (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.RUNNING"]], "shutting_down (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.SHUTTING_DOWN"]], "starting (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.STARTING"]], "success (airflow.providers.apache.livy.hooks.livy.batchstate attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.BatchState.SUCCESS"]], "terminal_states (airflow.providers.apache.livy.hooks.livy.livyasynchook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.TERMINAL_STATES"]], "terminal_states (airflow.providers.apache.livy.hooks.livy.livyhook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.TERMINAL_STATES"]], "airflow.providers.apache.livy.hooks.livy": [[1, "module-airflow.providers.apache.livy.hooks.livy"]], "build_post_batch_body() (airflow.providers.apache.livy.hooks.livy.livyasynchook static method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.build_post_batch_body"]], "build_post_batch_body() (airflow.providers.apache.livy.hooks.livy.livyhook static method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.build_post_batch_body"]], "conn_name_attr (airflow.providers.apache.livy.hooks.livy.livyasynchook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.conn_name_attr"]], "conn_name_attr (airflow.providers.apache.livy.hooks.livy.livyhook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.conn_name_attr"]], "conn_type (airflow.providers.apache.livy.hooks.livy.livyasynchook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.conn_type"]], "conn_type (airflow.providers.apache.livy.hooks.livy.livyhook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.conn_type"]], "default_conn_name (airflow.providers.apache.livy.hooks.livy.livyasynchook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.default_conn_name"]], "default_conn_name (airflow.providers.apache.livy.hooks.livy.livyhook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.default_conn_name"]], "delete_batch() (airflow.providers.apache.livy.hooks.livy.livyhook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.delete_batch"]], "dump_batch_logs() (airflow.providers.apache.livy.hooks.livy.livyasynchook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.dump_batch_logs"]], "dump_batch_logs() (airflow.providers.apache.livy.hooks.livy.livyhook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.dump_batch_logs"]], "get_batch() (airflow.providers.apache.livy.hooks.livy.livyhook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.get_batch"]], "get_batch_logs() (airflow.providers.apache.livy.hooks.livy.livyasynchook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.get_batch_logs"]], "get_batch_logs() (airflow.providers.apache.livy.hooks.livy.livyhook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.get_batch_logs"]], "get_batch_state() (airflow.providers.apache.livy.hooks.livy.livyasynchook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.get_batch_state"]], "get_batch_state() (airflow.providers.apache.livy.hooks.livy.livyhook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.get_batch_state"]], "get_conn() (airflow.providers.apache.livy.hooks.livy.livyhook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.get_conn"]], "hook_name (airflow.providers.apache.livy.hooks.livy.livyasynchook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.hook_name"]], "hook_name (airflow.providers.apache.livy.hooks.livy.livyhook attribute)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.hook_name"]], "post_batch() (airflow.providers.apache.livy.hooks.livy.livyhook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.post_batch"]], "run_method() (airflow.providers.apache.livy.hooks.livy.livyasynchook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyAsyncHook.run_method"]], "run_method() (airflow.providers.apache.livy.hooks.livy.livyhook method)": [[1, "airflow.providers.apache.livy.hooks.livy.LivyHook.run_method"]], "__version__ (in module airflow.providers.apache.livy)": [[2, "airflow.providers.apache.livy.__version__"]], "airflow.providers.apache.livy": [[2, "module-airflow.providers.apache.livy"]], "airflow.providers.apache.livy.operators": [[3, "module-airflow.providers.apache.livy.operators"]], "livyoperator (class in airflow.providers.apache.livy.operators.livy)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator"]], "airflow.providers.apache.livy.operators.livy": [[4, "module-airflow.providers.apache.livy.operators.livy"]], "execute() (airflow.providers.apache.livy.operators.livy.livyoperator method)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.execute"]], "execute_complete() (airflow.providers.apache.livy.operators.livy.livyoperator method)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.execute_complete"]], "get_hook() (airflow.providers.apache.livy.operators.livy.livyoperator method)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.get_hook"]], "hook() (airflow.providers.apache.livy.operators.livy.livyoperator method)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.hook"]], "kill() (airflow.providers.apache.livy.operators.livy.livyoperator method)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.kill"]], "on_kill() (airflow.providers.apache.livy.operators.livy.livyoperator method)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.on_kill"]], "poll_for_termination() (airflow.providers.apache.livy.operators.livy.livyoperator method)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.poll_for_termination"]], "template_fields (airflow.providers.apache.livy.operators.livy.livyoperator attribute)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.template_fields"]], "template_fields_renderers (airflow.providers.apache.livy.operators.livy.livyoperator attribute)": [[4, "airflow.providers.apache.livy.operators.livy.LivyOperator.template_fields_renderers"]], "airflow.providers.apache.livy.sensors": [[5, "module-airflow.providers.apache.livy.sensors"]], "livysensor (class in airflow.providers.apache.livy.sensors.livy)": [[6, "airflow.providers.apache.livy.sensors.livy.LivySensor"]], "airflow.providers.apache.livy.sensors.livy": [[6, "module-airflow.providers.apache.livy.sensors.livy"]], "get_hook() (airflow.providers.apache.livy.sensors.livy.livysensor method)": [[6, "airflow.providers.apache.livy.sensors.livy.LivySensor.get_hook"]], "poke() (airflow.providers.apache.livy.sensors.livy.livysensor method)": [[6, "airflow.providers.apache.livy.sensors.livy.LivySensor.poke"]], "template_fields (airflow.providers.apache.livy.sensors.livy.livysensor attribute)": [[6, "airflow.providers.apache.livy.sensors.livy.LivySensor.template_fields"]], "airflow.providers.apache.livy.triggers": [[7, "module-airflow.providers.apache.livy.triggers"]], "livytrigger (class in airflow.providers.apache.livy.triggers.livy)": [[8, "airflow.providers.apache.livy.triggers.livy.LivyTrigger"]], "airflow.providers.apache.livy.triggers.livy": [[8, "module-airflow.providers.apache.livy.triggers.livy"]], "poll_for_termination() (airflow.providers.apache.livy.triggers.livy.livytrigger method)": [[8, "airflow.providers.apache.livy.triggers.livy.LivyTrigger.poll_for_termination"]], "run() (airflow.providers.apache.livy.triggers.livy.livytrigger method)": [[8, "airflow.providers.apache.livy.triggers.livy.LivyTrigger.run"]], "serialize() (airflow.providers.apache.livy.triggers.livy.livytrigger method)": [[8, "airflow.providers.apache.livy.triggers.livy.LivyTrigger.serialize"]], "dag_id (in module tests.system.providers.apache.livy.example_livy)": [[9, "tests.system.providers.apache.livy.example_livy.DAG_ID"]], "env_id (in module tests.system.providers.apache.livy.example_livy)": [[9, "tests.system.providers.apache.livy.example_livy.ENV_ID"]], "livy_java_task (in module tests.system.providers.apache.livy.example_livy)": [[9, "tests.system.providers.apache.livy.example_livy.livy_java_task"]], "test_run (in module tests.system.providers.apache.livy.example_livy)": [[9, "tests.system.providers.apache.livy.example_livy.test_run"]], "tests.system.providers.apache.livy.example_livy": [[9, "module-tests.system.providers.apache.livy.example_livy"]], "tests.system.providers.apache.livy": [[10, "module-tests.system.providers.apache.livy"]]}}) |