| Search.setIndex({"docnames": ["_api/airflow/providers/celery/executors/celery_executor/index", "_api/airflow/providers/celery/executors/celery_executor_utils/index", "_api/airflow/providers/celery/executors/celery_kubernetes_executor/index", "_api/airflow/providers/celery/executors/default_celery/index", "_api/airflow/providers/celery/executors/index", "_api/airflow/providers/celery/index", "_api/airflow/providers/celery/sensors/celery_queue/index", "_api/airflow/providers/celery/sensors/index", "changelog", "commits", "configurations-ref", "index", "installing-providers-from-sources", "security"], "filenames": ["_api/airflow/providers/celery/executors/celery_executor/index.rst", "_api/airflow/providers/celery/executors/celery_executor_utils/index.rst", "_api/airflow/providers/celery/executors/celery_kubernetes_executor/index.rst", "_api/airflow/providers/celery/executors/default_celery/index.rst", "_api/airflow/providers/celery/executors/index.rst", "_api/airflow/providers/celery/index.rst", "_api/airflow/providers/celery/sensors/celery_queue/index.rst", "_api/airflow/providers/celery/sensors/index.rst", "changelog.rst", "commits.rst", "configurations-ref.rst", "index.rst", "installing-providers-from-sources.rst", "security.rst"], "titles": ["<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery.executors.celery_executor</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery.executors.celery_executor_utils</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery.executors.celery_kubernetes_executor</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery.executors.default_celery</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery.executors</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery.sensors.celery_queue</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery.sensors</span></code>", "Changelog", "Package apache-airflow-providers-celery", "Configuration Reference", "<code class=\"docutils literal notranslate\"><span class=\"pre\">apache-airflow-providers-celery</span></code>", "Installing from sources", "Releasing security patches"], "terms": {"celeryexecutor": [0, 2, 8, 9, 10], "For": [0, 1, 9, 10, 11, 12], "more": [0, 9, 10], "inform": [0, 9, 10, 13], "how": [0, 10, 12], "work": [0, 8, 10], "take": [0, 10], "look": 0, "guid": [0, 12], "base_vers": [0, 4], "sourc": [0, 1, 2, 3, 4, 5, 6], "log": [0, 1, 2, 3, 10], "celery_send_err_msg_head": 0, "error": [0, 1, 8, 9, 10], "send": [0, 1, 2, 10], "task": [0, 1, 2, 6, 10], "taskinstanceinceleri": [0, 1], "__getattr__": 0, "name": [0, 6, 9, 10], "arg_broker_api": 0, "arg_flower_hostnam": 0, "arg_flower_port": 0, "arg_flower_conf": 0, "arg_flower_url_prefix": 0, "arg_flower_basic_auth": 0, "arg_queu": 0, "arg_concurr": 0, "arg_celery_hostnam": 0, "arg_umask": 0, "arg_without_mingl": 0, "arg_without_gossip": 0, "celery_command": 0, "base": [0, 1, 2, 6, 10], "base_executor": [0, 2], "baseexecutor": [0, 2], "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "recommend": [0, 10, 12], "product": 0, "us": [0, 1, 2, 8, 9, 10, 11, 12, 13], "It": [0, 2, 8, 12], "allow": [0, 9, 10], "distribut": [0, 12], "execut": [0, 1, 2, 10], "instanc": [0, 2, 10], "multipl": [0, 10], "worker": [0, 10], "node": 0, "simpl": 0, "flexibl": 0, "reliabl": 0, "system": 0, "process": [0, 1, 10], "vast": 0, "amount": 0, "messag": [0, 10], "while": [0, 6, 10], "oper": [0, 9, 10], "tool": [0, 9], "requir": [0, 8, 10, 13], "maintain": 0, "supports_ad_hoc_ti_run": [0, 2], "bool": [0, 2], "true": [0, 2, 10], "supports_sentri": [0, 2], "start": [0, 1, 2, 10], "mai": [0, 9], "need": [0, 10, 11], "get": [0, 1, 8, 10, 12, 13], "thing": 0, "sync": [0, 10], "call": [0, 1, 2], "period": 0, "heartbeat": [0, 2], "method": [0, 1], "should": [0, 6, 10, 12, 13], "overrid": [0, 6], "thi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "perform": [0, 10], "gather": 0, "status": 0, "debug_dump": [0, 2], "respons": [0, 2], "sigusr2": [0, 2], "schedul": [0, 2, 6, 10], "update_all_task_st": 0, "updat": [0, 8, 9, 10], "state": [0, 1, 6, 10], "change_st": 0, "kei": [0, 1, 10, 12], "info": [0, 1], "none": [0, 1, 2, 6, 10, 12], "chang": [0, 9, 13], "paramet": [0, 1, 2, 6, 10], "model": [0, 2, 13], "taskinstancekei": [0, 2], "uniqu": 0, "str": [0, 1, 2, 6], "set": [0, 2, 10], "update_task_st": 0, "singl": 0, "end": [0, 2], "synchron": [0, 9], "fals": [0, 2, 10], "wait": [0, 6, 10], "previous": 0, "submit": 0, "job": [0, 2, 10], "complet": [0, 8], "termin": [0, 2], "when": [0, 2, 9, 10, 11, 13], "daemon": 0, "receiv": [0, 13], "sigterm": 0, "try_adopt_task_inst": [0, 2], "ti": [0, 2], "try": [0, 2], "adopt": [0, 2, 10], "run": [0, 1, 2, 8, 10, 12], "have": [0, 1, 2, 6, 8, 13], "been": [0, 2, 10], "abandon": [0, 2], "schedulerjob": [0, 2, 10], "dy": [0, 2], "anyth": [0, 2], "clear": [0, 2], "becom": [0, 2], "elig": [0, 2], "re": [0, 2, 10], "return": [0, 1, 2], "ani": [0, 1, 2, 6, 12], "taskinst": [0, 2], "were": [0, 2], "unabl": [0, 2, 10], "type": [0, 1, 2, 9, 10], "sequenc": [0, 2], "cleanup_stuck_queued_task": [0, 2], "handl": 0, "remnant": 0, "fail": [0, 10], "becaus": 0, "thei": 0, "stuck": 0, "queu": [0, 2], "can": [0, 1, 2, 8, 10, 11, 12, 13], "If": [0, 1, 8, 10, 12], "detect": 0, "mark": [0, 10], "up_for_retri": 0, "ha": [0, 8, 10], "remain": [0, 9], "retri": [0, 10], "doesn": [0, 1], "t": [0, 1, 10], "list": [0, 2, 9, 10], "clean": 0, "up": [0, 9, 10], "readabl": 0, "warn": [0, 9, 12], "static": [0, 2], "get_cli_command": [0, 2], "vend": [0, 8, 9], "cli": [0, 8, 9], "command": [0, 1, 2, 8, 9, 10], "includ": [0, 9, 10, 13], "expos": 0, "via": [0, 2, 10, 11, 12], "manag": [0, 12], "setup": [0, 9], "teardown": 0, "inspect": 0, "etc": 0, "3": [0, 1, 2, 3, 4, 5, 6, 7, 10, 11, 12, 13], "0": [0, 1, 2, 3, 4, 5, 6, 7, 10, 11, 12, 13], "2": [0, 1, 2, 3, 4, 5, 6, 7, 10, 11, 12, 13], "7": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "dev0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "an": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "experiment": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "featur": [0, 1, 2, 3, 4, 5, 6, 7, 9, 10, 11, 12, 13], "util": [1, 2], "much": 1, "code": [1, 12], "expens": 1, "import": [1, 8, 9, 10, 12], "load": [1, 9], "care": 1, "where": [1, 10, 13], "operation_timeout": 1, "celery_fetch_err_msg_head": 1, "fetch": [1, 2], "celery_configur": 1, "celery_app_nam": 1, "app": [1, 10], "on_celery_import_modul": 1, "arg": [1, 9], "kwarg": [1, 6], "preload": 1, "some": [1, 10], "onc": [1, 12], "so": [1, 2, 10, 13], "other": 1, "won": [1, 10], "again": 1, "each": 1, "add": [1, 8, 9], "5": [1, 8, 11], "per": [1, 9], "befor": [1, 10], "long": [1, 10], "matter": 1, "short": 1, "notic": 1, "impact": 1, "execute_command": 1, "command_to_exec": 1, "exceptionwithtraceback": 1, "except": [1, 13], "exception_traceback": 1, "wrapper": [1, 2], "propag": 1, "parent": 1, "from": [1, 2, 8, 11, 13], "subprocess": 1, "The": [1, 6, 8, 10, 11, 12, 13], "wrap": 1, "stacktrac": 1, "send_task_to_executor": [1, 10], "task_tupl": 1, "fetch_celery_task_st": [1, 10], "async_result": 1, "given": 1, "scope": [1, 13], "global": 1, "pool": [1, 2], "result": [1, 10], "asyncresult": 1, "tupl": 1, "async": 1, "object": 1, "": [1, 9, 12], "bulkstatefetch": 1, "sync_parallel": 1, "logging_mixin": [1, 2], "loggingmixin": [1, 2], "statu": [1, 10], "mani": [1, 10], "best": 1, "avail": [1, 8, 10, 12], "basekeyvaluestorebackend": 1, "backend": [1, 10], "mget": 1, "databasebackend": 1, "select": [1, 2, 12], "task_id": 1, "IN": 1, "queri": 1, "otherwis": [1, 2, 8, 10], "multiprocess": 1, "download": [1, 12], "individu": 1, "get_mani": 1, "celerykubernetesexecutor": [2, 8, 10], "celery_executor": [2, 4, 5, 10], "kubernetes_executor": 2, "consist": 2, "kubernetesexecutor": [2, 10], "choos": [2, 12], "queue": [2, 6, 10], "defin": [2, 6, 10], "valu": [2, 10], "kubernetes_queu": 2, "section": 2, "configur": [2, 3, 9], "default": [2, 3, 6, 8, 9, 10, 13], "kubernet": [2, 8, 9, 10, 11], "properti": 2, "queued_task": 2, "dict": [2, 3], "queuedtaskinstancetyp": 2, "job_id": 2, "int": 2, "inherit": 2, "attribut": 2, "sinc": [2, 10], "realli": 2, "we": [2, 13], "implement": [2, 9, 10], "custom": 2, "setter": 2, "slots_avail": 2, "number": [2, 9, 10], "new": [2, 9, 13], "accept": [2, 10], "supports_pickl": 2, "is_loc": 2, "is_single_thread": 2, "is_product": 2, "serve_log": 2, "change_sensor_mode_to_reschedul": 2, "callback_sink": 2, "callback": 2, "base_callback_sink": 2, "basecallbacksink": 2, "queue_command": 2, "task_inst": 2, "prioriti": 2, "1": [2, 10, 11], "queue_task_inst": 2, "mark_success": 2, "pickle_id": 2, "ignore_all_dep": 2, "ignore_depends_on_past": 2, "wait_for_past_depends_before_skip": 2, "ignore_task_dep": 2, "ignore_ti_st": 2, "cfg_path": 2, "get_task_log": 2, "try_numb": 2, "has_task": 2, "check": [2, 6, 9, 10, 12], "either": 2, "known": 2, "sent": 2, "trigger": 2, "get_event_buff": 2, "dag_id": 2, "flush": 2, "event": 2, "buffer": 2, "all": [2, 8, 9, 10, 11, 13], "eventbuffervaluetyp": 2, "send_callback": 2, "request": 2, "callback_request": 2, "callbackrequest": 2, "broker_url": 3, "broker_transport_opt": [3, 10], "broker_transport_options_for_celeri": 3, "sentinel_kwarg": 3, "result_backend": 3, "default_celery_config": [3, 10], "celery_ssl_act": 3, "broker_use_ssl": 3, "celery_executor_util": [4, 5], "celery_kubernetes_executor": [4, 5], "default_celeri": [4, 5, 8, 9, 10], "executor": [5, 8, 9, 10], "sensor": [5, 9], "celery_queu": [5, 7], "__version__": [5, 9], "celeryqueuesensor": 6, "target_task_id": 6, "basesensoroper": 6, "empti": 6, "By": [6, 12], "order": [6, 8, 11], "consid": 6, "must": 6, "reserv": 6, "activ": 6, "id": [6, 12], "poke": 6, "context": [6, 9], "function": 6, "deriv": 6, "apach": [8, 10, 12], "airflow": [8, 10, 12, 13], "provid": [8, 10, 12, 13], "celeri": [8, 12], "releas": [8, 9, 11], "first": 8, "move": [8, 9, 10], "core": [8, 9, 10], "packag": 8, "also": [8, 12], "expect": 8, "cncf": [8, 9, 11], "version": [8, 9, 10, 11, 12, 13], "instal": [8, 9, 13], "you": [8, 10, 11, 12, 13], "extra": [8, 9, 11], "pip": [8, 9, 11, 12], "right": 8, "32526": [8, 9], "pre": [8, 9], "hardcod": [8, 9], "config": [8, 9], "older": [8, 9, 13], "32775": [8, 9], "aip": [8, 9], "51": [8, 9], "29055": [8, 9], "k8": [8, 9], "class": [8, 9, 11], "32767": [8, 9], "discoveri": [8, 9], "document": [8, 9, 10], "32532": [8, 9], "py": [8, 9], "insid": [8, 9], "32628": [8, 9], "rais": [8, 9], "origin": [8, 9, 12], "32931": [8, 9], "drop": [8, 9, 12], "support": [8, 9, 10, 11], "python": [8, 9, 11, 12], "note": [8, 9, 10], "about": [8, 9, 12, 13], "32015": [8, 9], "onli": [8, 10, 13], "explain": 8, "polici": [8, 13], "bump": [8, 9], "minimum": [8, 9, 10, 11], "30917": [8, 9], "min": [8, 9], "27196": [8, 9], "our": [8, 9], "approach": [8, 9], "bound": [8, 9], "depend": [8, 9, 10, 13], "22573": [8, 9], "mistakenli": 8, "ad": [8, 9], "install_requir": 8, "22382": 8, "trove": 8, "classifi": [8, 9], "pypi": [8, 9, 11, 13], "framework": 8, "10": [8, 9], "convert": 8, "follow": [8, 12, 13], "auto": [8, 9], "appli": [8, 9, 10], "apply_default": [8, 9], "decor": [8, 9], "15667": [8, 9], "due": [8, 10], "remov": [8, 9, 12], "your": [8, 10], "want": [8, 12, 13], "upgrad": [8, 9, 13], "least": 8, "automat": 8, "manual": 8, "db": [8, 10], "migrat": 8, "readm": [8, 9], "file": [8, 9, 10, 12], "initi": 8, "detail": [9, 12], "commit": 9, "high": 9, "level": 9, "changelog": 9, "see": [9, 10, 11], "latest": [9, 10, 13], "2023": 9, "07": 9, "29": 9, "subject": 9, "f31af91dbd": 9, "fcbbf47864": 9, "e93460383f": 9, "26": 9, "2ac237b3eb": 9, "24": 9, "56c41d460c": 9, "22": 9, "introduc": 9, "32765": 9, "73b90c48b1": 9, "21": 9, "contribut": 9, "32604": 9, "ea0deaa993": 9, "16": [9, 10], "624211f33f": 9, "12": [9, 10, 12], "40d54eac1a": 9, "225e3041d2": 9, "06": 9, "prepar": [9, 13], "doc": [9, 10], "juli": 9, "wave": 9, "rc2": 9, "32381": 9, "3878fe6fab": 9, "05": 9, "spuriou": 9, "header": 9, "32373": 9, "cb4927a018": 9, "32298": 9, "8c37b74a20": 9, "28": 9, "d205": 9, "common": 9, "inclus": 9, "32226": 9, "09d4718d3a": 9, "27": 9, "improv": [9, 10], "structur": 9, "32125": 9, "20": 9, "79bcc2e668": 9, "rc1": 9, "june": 9, "32001": 9, "8b146152d6": 9, "19": 9, "45548b9451": 9, "31416": 9, "abea189022": 9, "18": 9, "31393": 9, "f5aed58d9f": 9, "fix": [9, 13], "circular": 9, "caus": 9, "31379": 9, "d9ff55cf6d": 9, "31252": 9, "eef5bc7f16": 9, "03": 9, "full": 9, "autom": 9, "30994": 9, "a7eb32a5b2": 9, "04": 9, "30": 9, "d23a3bbed8": 9, "mechan": 9, "suspend": 9, "30422": 9, "2022": 9, "11": [9, 12], "15": 9, "12c3c39d1a": 9, "novemb": 9, "27613": 9, "9ab1a6a3e7": 9, "old": 9, "style": 9, "26872": 9, "78b8ea2f22": 9, "2a34dc9e84": 9, "23": 9, "enabl": [9, 10], "string": [9, 10], "normal": 9, "format": [9, 10], "27205": 9, "f8db64c35c": 9, "09": 9, "septemb": 9, "26731": 9, "06acf40a43": 9, "13": 9, "pep": 9, "563": 9, "postpon": 9, "evalu": 9, "annot": 9, "non": 9, "26289": 9, "e5ac6c7cfb": 9, "08": 9, "august": 9, "25618": 9, "d2459a241b": 9, "25030": 9, "0de31bd73a": 9, "folder": [9, 12], "24672": 9, "dcdcf3a2b8": 9, "24307": 9, "717a7588bc": 9, "descript": 9, "doubl": 9, "specif": 9, "24292": 9, "aeabe994b3": 9, "24231": 9, "027b707d21": 9, "explanatori": 9, "contributor": 9, "24229": 9, "56ab82ed7a": 9, "mid": 9, "april": 9, "22819": 9, "6db30f3207": 9, "d7dbfb7e26": 9, "bugfix": [9, 13], "22383": 9, "14": 9, "16adc035b1": 9, "march": 9, "22226": 9, "f5b96315fe": 9, "feb": 9, "22056": 9, "d94fa37830": 9, "02": 9, "januari": 9, "delai": 9, "21439": 9, "6c3a67d4fc": 9, "2021": [9, 12], "21257": 9, "602abe8394": 9, "01": 9, "line": 9, "now": 9, "sphinx": 9, "autoapi": 9, "typehint": 9, "20951": 9, "f77417eb0d": 9, "31": 9, "compat": 9, "20614": 9, "97496ba2b4": 9, "decemb": 9, "20523": 9, "a0821235fb": 9, "everywher": 9, "20565": 9, "fd5d65751c": 9, "18018": 9, "bbc627a3da": 9, "16501": 9, "cbf8001d76": 9, "after": 9, "buggfix": 9, "16464": 9, "1fba5402bb": 9, "16405": 9, "9c94b72d44": 9, "16294": 9, "37681bca00": 9, "807ad32ce5": 9, "15576": 9, "40a2476a5d": 9, "interact": 9, "gener": 9, "15518": 9, "68e4c4dcb0": 9, "backport": 9, "14886": 9, "6e6526a0f6": 9, "broken": 9, "14734": 9, "88bdcfa0df": 9, "14013": 9, "ac2f72c98d": 9, "13767": 9, "3fd5ef3555": 9, "miss": 9, "logo": 9, "integr": 9, "13717": 9, "295d66f914": 9, "2020": 9, "grammar": 9, "13380": 9, "6cf76d7ac0": 9, "typo": 9, "13148": 9, "32971a1a2d": 9, "12955": 9, "b40dffa085": 9, "renam": 9, "rema": 9, "modul": 9, "match": [9, 10, 12], "12917": 9, "c34ef853c8": 9, "separ": [9, 10, 13], "out": [9, 10, 13], "build": [9, 12], "12444": 9, "0080354502": 9, "0b2": 9, "batch": 9, "12449": 9, "ae7cb4a1e2": 9, "17": 9, "wrong": 9, "hash": 9, "12390": 9, "6889a333cf": 9, "hook": 9, "ref": 9, "12366": 9, "7825e8f590": 9, "12304": 9, "85a18e13d9": 9, "point": 9, "project": 9, "page": [9, 10, 12], "cross": 9, "12212": 9, "59eb5de78c": 9, "come": 9, "0beta1": 9, "12206": 9, "b2a28d1590": 9, "script": [9, 12], "dev": [9, 10], "12082": 9, "4e8f9cc8d0": 9, "black": 9, "formmatt": 9, "9550": 9, "8c42cf1b00": 9, "pyupgrad": 9, "6": [9, 10, 11], "11447": 9, "5a439e84eb": 9, "2a1": 9, "11855": 9, "872b1566a1": 9, "25": 9, "11826": 9, "16e7129719": 9, "11487": 9, "0a0e1af800": 9, "markdown": 9, "link": [9, 12], "toc": 9, "11249": 9, "ca4238eb4d": 9, "month": 9, "octob": 9, "11242": 9, "5220e4c384": 9, "11238": 9, "fdd9b6f65b": 9, "10543": 9, "3696c34c28": 9, "word": 9, "10528": 9, "ee7ca128a1": 9, "refernc": 9, "10483": 9, "cdec301254": 9, "correct": [9, 12], "signatur": [9, 11, 12], "10205": 9, "24c8e4c2d6": 9, "constructor": 9, "argument": 9, "10163": 9, "5bb228d841": 9, "hint": 9, "9762": 9, "d0e7db4024": 9, "fresh": 9, "9408": 9, "12af6a0800": 9, "final": 9, "cleanup": 9, "23rc1": 9, "9404": 9, "c7e5bce57f": 9, "candid": 9, "9370": 9, "f6bd817a3a": 9, "transfer": 9, "9320": 9, "0b0e4f7a4c": 9, "rc3": 9, "relas": 9, "9026": 9, "00642a46d0": 9, "wrongli": 9, "8994": 9, "375d1ca229": 9, "8898": 9, "12c5e5d8a": 9, "8891": 9, "f3521fb0e3": 9, "regener": 9, "8886": 9, "92585ca4cb": 9, "8807": 9, "97a429f9d0": 9, "6714": 9, "magic": 9, "comment": 9, "utf": 9, "8": 9, "7338": 9, "059eda05f8": 9, "6610": 9, "softwar": [9, 12], "7231": 9, "contain": [10, 12], "cfg": 10, "environ": 10, "variabl": 10, "option": 10, "ar": [10, 11, 12, 13], "abov": [10, 12], "broker": 10, "url": 10, "rabbitmq": 10, "redi": 10, "sqlalchemi": 10, "databas": 10, "6379": 10, "airflow__celery__broker_url": 10, "airflow__celery__broker_url_cmd": 10, "airflow__celery__broker_url_secret": 10, "airflow__celery__celery_app_nam": 10, "path": 10, "airflow__celery__celery_config_opt": 10, "secur": 10, "flower": [10, 11], "basic": 10, "authent": 10, "user": [10, 12], "password": 10, "pair": 10, "comma": 10, "airflow__celery__flower_basic_auth": 10, "airflow__celery__flower_basic_auth_cmd": 10, "airflow__celery__flower_basic_auth_secret": 10, "exampl": [10, 11, 12], "user1": 10, "password1": 10, "user2": 10, "password2": 10, "sweet": 10, "ui": 10, "shortcut": 10, "ip": 10, "airflow__celery__flower_host": 10, "port": 10, "5555": 10, "airflow__celery__flower_port": 10, "root": 10, "airflow__celery__flower_url_prefix": 10, "second": 10, "time": 10, "float": 10, "airflow__celery__operation_timeout": 10, "choic": 10, "prefork": 10, "eventlet": 10, "gevent": 10, "solo": 10, "http": [10, 12], "celeryproject": 10, "org": [10, 12], "en": 10, "userguid": 10, "html": 10, "concurr": 10, "airflow__celery__pool": 10, "finish": 10, "metadata": 10, "therefor": 10, "post": 10, "bu": 10, "insert": 10, "highli": 10, "specifi": [10, 11], "sql_alchemy_conn": 10, "scheme": 10, "prefix": 10, "airflow__celery__result_backend": 10, "airflow__celery__result_backend_cmd": 10, "airflow__celery__result_backend_secret": 10, "postgresql": 10, "postgr": 10, "dictionari": 10, "pass": 10, "engin": 10, "airflow__celery__result_backend_sqlalchemy_engine_opt": 10, "pool_recycl": 10, "1800": 10, "airflow__celery__ssl_act": 10, "ca": 10, "certif": [10, 12], "airflow__celery__ssl_cacert": 10, "client": 10, "airflow__celery__ssl_cert": 10, "airflow__celery__ssl_kei": 10, "mean": 10, "max": 10, "airflow__celery__sync_parallel": 10, "maximum": 10, "publish": [10, 13], "airflowtasktimeout": 10, "give": 10, "integ": 10, "airflow__celery__task_publish_max_retri": 10, "report": 10, "its": 10, "keep": 10, "track": 10, "restart": 10, "mode": 10, "orphan": 10, "launch": 10, "previou": [10, 12], "boolean": 10, "airflow__celery__task_track_start": 10, "alwai": [10, 13], "grow": 10, "necessari": 10, "max_concurr": 10, "min_concurr": 10, "pick": [10, 13], "resourc": 10, "box": 10, "natur": 10, "autoscal": 10, "ignor": 10, "bin": [10, 12], "cmdoption": 10, "airflow__celery__worker_autoscal": 10, "size": 10, "airflow__celery__worker_concurr": 10, "remot": 10, "control": 10, "In": 10, "case": [10, 13], "doe": 10, "creat": [10, 12], "lot": 10, "repli": 10, "pidbox": 10, "prevent": 10, "howev": 10, "disabl": 10, "celeryq": 10, "stabl": 10, "index": 10, "overview": 10, "airflow__celery__worker_enable_remote_control": 10, "initialis": 10, "valid": [10, 12], "connect": 10, "airflow__celery__worker_precheck": 10, "increas": 10, "prefetch": 10, "which": [10, 13], "multipli": 10, "A": 10, "greater": 10, "than": 10, "being": 10, "unnecessarili": 10, "block": 10, "one": [10, 12], "sit": 10, "behind": 10, "anoth": 10, "unutil": 10, "alreadi": [10, 12], "claim": 10, "optim": 10, "limit": 10, "airflow__celery__worker_prefetch_multipli": 10, "task_queued_timeout": 10, "underli": 10, "transport": 10, "std": 10, "addit": 10, "sentinel": 10, "typic": 10, "scenario": 10, "server": [10, 12], "protect": 10, "through": 10, "although": 10, "conform": 10, "airflow__celery_broker_transport_options__sentinel_kwarg": 10, "airflow__celery_broker_transport_options__sentinel_kwargs_cmd": 10, "airflow__celery_broker_transport_options__sentinel_kwargs_secret": 10, "password_for_redis_serv": 10, "visibl": 10, "timeout": 10, "acknowledg": 10, "redeliv": 10, "make": 10, "sure": 10, "longest": 10, "eta": 10, "plan": 10, "sq": 10, "airflow__celery_broker_transport_options__visibility_timeout": 10, "21600": 10, "airflow__celery_kubernetes_executor__kubernetes_queu": 10, "top": [11, 12], "exist": 11, "below": [11, 12], "4": 11, "those": [11, 12], "might": [11, 13], "them": 11, "verifi": 11, "checksum": [11, 12], "site": 11, "sdist": [11, 12], "asc": [11, 12], "sha512": [11, 12], "wheel": 11, "describ": 12, "offici": 12, "most": 12, "differ": 12, "down": 12, "left": 12, "whl": 12, "foundat": 12, "pgp": 12, "essenti": 12, "sha": 12, "gpg": 12, "pleas": 12, "well": 12, "relev": 12, "main": [12, 13], "directori": 12, "mirror": 12, "pgpk": 12, "ka": 12, "To": 12, "binari": 12, "pgpv": 12, "tar": 12, "gz": 12, "made": 12, "sat": 12, "sep": 12, "49": 12, "54": 12, "bst": 12, "rsa": 12, "cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f": 12, "issuer": 12, "kaxilnaik": 12, "good": [12, 13], "kaxil": 12, "naik": 12, "unknown": 12, "aka": 12, "gmail": 12, "com": 12, "certifi": 12, "trust": 12, "There": 12, "indic": 12, "belong": 12, "owner": 12, "primari": 12, "fingerprint": 12, "cde1": 12, "5c6e": 12, "4d3a": 12, "8ec4": 12, "ecf4": 12, "ba4b": 12, "6674": 12, "e08a": 12, "d7de": 12, "406f": 12, "do": 12, "worri": 12, "self": 12, "sign": 12, "why": 12, "step": 12, "know": 12, "sum": 12, "shasum": 12, "512": 12, "diff": 12, "local": 12, "bash": 12, "package_vers": 12, "package_nam": 12, "provider_download_dir": 12, "mktemp": 12, "d": 12, "dep": 12, "dest": 12, "curl": 12, "apache_airflow_providers_celeri": 12, "py3": 12, "l": 12, "o": 12, "echo": 12, "la": 12, "instruct": [12, 13], "chapter": 12, "temporari": 12, "independ": 13, "itself": 13, "vulner": 13, "found": 13, "develop": 13, "done": 13, "branch": 13, "next": 13, "strict": 13, "semver": 13, "major": 13, "break": 13, "minor": 13, "patchlevel": 13, "bug": 13, "rule": 13, "critic": 13, "reason": 13, "band": 13, "stakehold": 13, "decid": 13, "cherri": 13, "mix": 13, "govern": 13, "interest": 13, "parti": 13, "test": 13}, "objects": {"airflow.providers": [[5, 0, 0, "-", "celery"]], "airflow.providers.celery": [[5, 1, 1, "", "__version__"], [4, 0, 0, "-", "executors"], [7, 0, 0, "-", "sensors"]], "airflow.providers.celery.executors": [[4, 1, 1, "", "base_version"], [0, 0, 0, "-", "celery_executor"], [1, 0, 0, "-", "celery_executor_utils"], [2, 0, 0, "-", "celery_kubernetes_executor"], [3, 0, 0, "-", "default_celery"]], "airflow.providers.celery.executors.celery_executor": [[0, 1, 1, "", "ARG_BROKER_API"], [0, 1, 1, "", "ARG_CELERY_HOSTNAME"], [0, 1, 1, "", "ARG_CONCURRENCY"], [0, 1, 1, "", "ARG_FLOWER_BASIC_AUTH"], [0, 1, 1, "", "ARG_FLOWER_CONF"], [0, 1, 1, "", "ARG_FLOWER_HOSTNAME"], [0, 1, 1, "", "ARG_FLOWER_PORT"], [0, 1, 1, "", "ARG_FLOWER_URL_PREFIX"], [0, 1, 1, "", "ARG_QUEUES"], [0, 1, 1, "", "ARG_UMASK"], [0, 1, 1, "", "ARG_WITHOUT_GOSSIP"], [0, 1, 1, "", "ARG_WITHOUT_MINGLE"], [0, 1, 1, "", "CELERY_COMMANDS"], [0, 1, 1, "", "CELERY_SEND_ERR_MSG_HEADER"], [0, 2, 1, "", "CeleryExecutor"], [0, 1, 1, "", "TaskInstanceInCelery"], [0, 5, 1, "", "__getattr__"], [0, 1, 1, "", "base_version"], [0, 1, 1, "", "log"]], "airflow.providers.celery.executors.celery_executor.CeleryExecutor": [[0, 3, 1, "", "change_state"], [0, 3, 1, "", "cleanup_stuck_queued_tasks"], [0, 3, 1, "", "debug_dump"], [0, 3, 1, "", "end"], [0, 3, 1, "", "get_cli_commands"], [0, 3, 1, "", "start"], [0, 4, 1, "", "supports_ad_hoc_ti_run"], [0, 4, 1, "", "supports_sentry"], [0, 3, 1, "", "sync"], [0, 3, 1, "", "terminate"], [0, 3, 1, "", "try_adopt_task_instances"], [0, 3, 1, "", "update_all_task_states"], [0, 3, 1, "", "update_task_state"]], "airflow.providers.celery.executors.celery_executor_utils": [[1, 2, 1, "", "BulkStateFetcher"], [1, 1, 1, "", "CELERY_FETCH_ERR_MSG_HEADER"], [1, 2, 1, "", "ExceptionWithTraceback"], [1, 1, 1, "", "OPERATION_TIMEOUT"], [1, 1, 1, "", "TaskInstanceInCelery"], [1, 1, 1, "", "app"], [1, 1, 1, "", "celery_app_name"], [1, 1, 1, "", "celery_configuration"], [1, 5, 1, "", "execute_command"], [1, 5, 1, "", "fetch_celery_task_state"], [1, 1, 1, "", "log"], [1, 5, 1, "", "on_celery_import_modules"], [1, 5, 1, "", "send_task_to_executor"]], "airflow.providers.celery.executors.celery_executor_utils.BulkStateFetcher": [[1, 3, 1, "", "get_many"]], "airflow.providers.celery.executors.celery_kubernetes_executor": [[2, 2, 1, "", "CeleryKubernetesExecutor"]], "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor": [[2, 4, 1, "", "callback_sink"], [2, 4, 1, "", "change_sensor_mode_to_reschedule"], [2, 3, 1, "", "cleanup_stuck_queued_tasks"], [2, 3, 1, "", "debug_dump"], [2, 3, 1, "", "end"], [2, 3, 1, "", "get_cli_commands"], [2, 3, 1, "", "get_event_buffer"], [2, 3, 1, "", "get_task_log"], [2, 3, 1, "", "has_task"], [2, 3, 1, "", "heartbeat"], [2, 4, 1, "", "is_local"], [2, 4, 1, "", "is_production"], [2, 4, 1, "", "is_single_threaded"], [2, 6, 1, "", "job_id"], [2, 3, 1, "", "kubernetes_queue"], [2, 3, 1, "", "queue_command"], [2, 3, 1, "", "queue_task_instance"], [2, 6, 1, "", "queued_tasks"], [2, 6, 1, "", "running"], [2, 3, 1, "", "send_callback"], [2, 4, 1, "", "serve_logs"], [2, 6, 1, "", "slots_available"], [2, 3, 1, "", "start"], [2, 4, 1, "", "supports_ad_hoc_ti_run"], [2, 4, 1, "", "supports_pickling"], [2, 4, 1, "", "supports_sentry"], [2, 3, 1, "", "terminate"], [2, 3, 1, "", "try_adopt_task_instances"]], "airflow.providers.celery.executors.default_celery": [[3, 1, 1, "", "DEFAULT_CELERY_CONFIG"], [3, 1, 1, "", "broker_transport_options"], [3, 1, 1, "", "broker_transport_options_for_celery"], [3, 1, 1, "", "broker_url"], [3, 1, 1, "", "broker_use_ssl"], [3, 1, 1, "", "celery_ssl_active"], [3, 1, 1, "", "log"], [3, 1, 1, "", "result_backend"], [3, 1, 1, "", "sentinel_kwargs"]], "airflow.providers.celery.sensors": [[6, 0, 0, "-", "celery_queue"]], "airflow.providers.celery.sensors.celery_queue": [[6, 2, 1, "", "CeleryQueueSensor"]], "airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor": [[6, 3, 1, "", "poke"]]}, "objtypes": {"0": "py:module", "1": "py:data", "2": "py:class", "3": "py:method", "4": "py:attribute", "5": "py:function", "6": "py:property"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "data", "Python data"], "2": ["py", "class", "Python class"], "3": ["py", "method", "Python method"], "4": ["py", "attribute", "Python attribute"], "5": ["py", "function", "Python function"], "6": ["py", "property", "Python property"]}, "titleterms": {"airflow": [0, 1, 2, 3, 4, 5, 6, 7, 9, 11], "provid": [0, 1, 2, 3, 4, 5, 6, 7, 9, 11], "celeri": [0, 1, 2, 3, 4, 5, 6, 7, 9, 10, 11], "executor": [0, 1, 2, 3, 4], "celery_executor": 0, "modul": [0, 1, 2, 3, 6], "content": [0, 1, 2, 3, 4, 5, 6], "class": [0, 1, 2, 6], "function": [0, 1], "attribut": [0, 1], "celery_executor_util": 1, "celery_kubernetes_executor": [2, 10], "default_celeri": 3, "submodul": [4, 7], "packag": [4, 5, 9, 11, 12], "subpackag": 5, "sensor": [6, 7], "celery_queu": 6, "changelog": 8, "3": [8, 9], "0": [8, 9], "featur": 8, "misc": 8, "2": [8, 9], "1": [8, 9], "break": 8, "chang": 8, "4": [8, 9], "bug": 8, "fix": 8, "apach": [9, 11], "configur": 10, "refer": 10, "section": 10, "broker_url": 10, "celery_app_nam": 10, "celery_config_opt": 10, "flower_basic_auth": 10, "flower_host": 10, "flower_port": 10, "flower_url_prefix": 10, "operation_timeout": 10, "pool": 10, "result_backend": 10, "result_backend_sqlalchemy_engine_opt": 10, "ssl_activ": 10, "ssl_cacert": 10, "ssl_cert": 10, "ssl_kei": 10, "sync_parallel": 10, "task_publish_max_retri": 10, "task_track_start": 10, "worker_autoscal": 10, "worker_concurr": 10, "worker_enable_remote_control": 10, "worker_precheck": 10, "worker_prefetch_multipli": 10, "default_queu": 10, "deprec": 10, "stalled_task_timeout": 10, "task_adoption_timeout": 10, "worker_log_server_port": 10, "celery_broker_transport_opt": 10, "sentinel_kwarg": 10, "visibility_timeout": 10, "kubernetes_queu": 10, "instal": [11, 12], "requir": 11, "cross": 11, "depend": 11, "download": 11, "offici": 11, "from": 12, "sourc": 12, "releas": [12, 13], "integr": 12, "verifi": 12, "pypi": 12, "secur": 13, "patch": 13}, "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.celery.executors.celery_executor": [[0, "module-airflow.providers.celery.executors.celery_executor"]], "Module Contents": [[0, "module-contents"], [1, "module-contents"], [2, "module-contents"], [3, "module-contents"], [6, "module-contents"]], "Classes": [[0, "classes"], [1, "classes"], [2, "classes"], [6, "classes"]], "Functions": [[0, "functions"], [1, "functions"]], "Attributes": [[0, "attributes"], [1, "attributes"]], "airflow.providers.celery.executors.celery_executor_utils": [[1, "module-airflow.providers.celery.executors.celery_executor_utils"]], "airflow.providers.celery.executors.celery_kubernetes_executor": [[2, "module-airflow.providers.celery.executors.celery_kubernetes_executor"]], "airflow.providers.celery.executors.default_celery": [[3, "module-airflow.providers.celery.executors.default_celery"]], "airflow.providers.celery.executors": [[4, "module-airflow.providers.celery.executors"]], "Submodules": [[4, "submodules"], [7, "submodules"]], "Package Contents": [[4, "package-contents"], [5, "package-contents"]], "airflow.providers.celery": [[5, "module-airflow.providers.celery"]], "Subpackages": [[5, "subpackages"]], "airflow.providers.celery.sensors.celery_queue": [[6, "module-airflow.providers.celery.sensors.celery_queue"]], "airflow.providers.celery.sensors": [[7, "module-airflow.providers.celery.sensors"]], "Changelog": [[8, "changelog"]], "3.3.0": [[8, "id1"], [9, "id1"]], "Features": [[8, "features"], [8, "id19"]], "Misc": [[8, "misc"], [8, "id3"], [8, "id5"], [8, "id8"], [8, "id12"], [8, "id15"], [8, "id17"]], "3.2.1": [[8, "id2"], [9, "id2"]], "3.2.0": [[8, "id4"], [9, "id3"]], "3.1.0": [[8, "id6"], [9, "id4"]], "3.0.0": [[8, "id9"], [9, "id5"]], "Breaking changes": [[8, "breaking-changes"], [8, "id21"]], "2.1.4": [[8, "id11"], [9, "id6"]], "2.1.3": [[8, "id13"], [9, "id7"]], "Bug Fixes": [[8, "bug-fixes"]], "2.1.2": [[8, "id14"], [9, "id8"]], "2.1.1": [[8, "id16"], [9, "id9"]], "2.1.0": [[8, "id18"], [9, "id10"]], "2.0.0": [[8, "id20"], [9, "id11"]], "1.0.1": [[8, "id22"], [9, "id12"]], "1.0.0": [[8, "id23"], [9, "id13"]], "Package apache-airflow-providers-celery": [[9, "package-apache-airflow-providers-celery"], [11, "package-apache-airflow-providers-celery"]], "Configuration Reference": [[10, "configuration-reference"]], "Sections:": [[10, "sections"]], "[celery]": [[10, "celery"]], "broker_url": [[10, "broker-url"]], "celery_app_name": [[10, "celery-app-name"]], "celery_config_options": [[10, "celery-config-options"]], "flower_basic_auth": [[10, "flower-basic-auth"]], "flower_host": [[10, "flower-host"]], "flower_port": [[10, "flower-port"]], "flower_url_prefix": [[10, "flower-url-prefix"]], "operation_timeout": [[10, "operation-timeout"]], "pool": [[10, "pool"]], "result_backend": [[10, "result-backend"]], "result_backend_sqlalchemy_engine_options": [[10, "result-backend-sqlalchemy-engine-options"]], "ssl_active": [[10, "ssl-active"]], "ssl_cacert": [[10, "ssl-cacert"]], "ssl_cert": [[10, "ssl-cert"]], "ssl_key": [[10, "ssl-key"]], "sync_parallelism": [[10, "sync-parallelism"]], "task_publish_max_retries": [[10, "task-publish-max-retries"]], "task_track_started": [[10, "task-track-started"]], "worker_autoscale": [[10, "worker-autoscale"]], "worker_concurrency": [[10, "worker-concurrency"]], "worker_enable_remote_control": [[10, "worker-enable-remote-control"]], "worker_precheck": [[10, "worker-precheck"]], "worker_prefetch_multiplier": [[10, "worker-prefetch-multiplier"]], "default_queue (Deprecated)": [[10, "default-queue-deprecated"]], "stalled_task_timeout (Deprecated)": [[10, "stalled-task-timeout-deprecated"]], "task_adoption_timeout (Deprecated)": [[10, "task-adoption-timeout-deprecated"]], "worker_log_server_port (Deprecated)": [[10, "worker-log-server-port-deprecated"]], "[celery_broker_transport_options]": [[10, "celery-broker-transport-options"]], "sentinel_kwargs": [[10, "sentinel-kwargs"]], "visibility_timeout": [[10, "visibility-timeout"]], "[celery_kubernetes_executor]": [[10, "celery-kubernetes-executor"]], "kubernetes_queue": [[10, "kubernetes-queue"]], "apache-airflow-providers-celery": [[11, "apache-airflow-providers-celery"]], "Provider package": [[11, "provider-package"]], "Installation": [[11, "installation"]], "Requirements": [[11, "requirements"]], "Cross provider package dependencies": [[11, "cross-provider-package-dependencies"]], "Downloading official packages": [[11, "downloading-official-packages"]], "Installing from sources": [[12, "installing-from-sources"]], "Released packages": [[12, "released-packages"]], "Release integrity": [[12, "release-integrity"]], "Verifying PyPI releases": [[12, "verifying-pypi-releases"]], "Releasing security patches": [[13, "releasing-security-patches"]]}, "indexentries": {"arg_broker_api (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_BROKER_API"]], "arg_celery_hostname (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_CELERY_HOSTNAME"]], "arg_concurrency (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_CONCURRENCY"]], "arg_flower_basic_auth (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_BASIC_AUTH"]], "arg_flower_conf (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_CONF"]], "arg_flower_hostname (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_HOSTNAME"]], "arg_flower_port (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_PORT"]], "arg_flower_url_prefix (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_URL_PREFIX"]], "arg_queues (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_QUEUES"]], "arg_umask (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_UMASK"]], "arg_without_gossip (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_WITHOUT_GOSSIP"]], "arg_without_mingle (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.ARG_WITHOUT_MINGLE"]], "celery_commands (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.CELERY_COMMANDS"]], "celery_send_err_msg_header (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.CELERY_SEND_ERR_MSG_HEADER"]], "celeryexecutor (class in airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor"]], "taskinstanceincelery (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.TaskInstanceInCelery"]], "__getattr__() (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.__getattr__"]], "airflow.providers.celery.executors.celery_executor": [[0, "module-airflow.providers.celery.executors.celery_executor"]], "base_version (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.base_version"]], "change_state() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.change_state"]], "cleanup_stuck_queued_tasks() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.cleanup_stuck_queued_tasks"]], "debug_dump() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.debug_dump"]], "end() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.end"]], "get_cli_commands() (airflow.providers.celery.executors.celery_executor.celeryexecutor static method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.get_cli_commands"]], "log (in module airflow.providers.celery.executors.celery_executor)": [[0, "airflow.providers.celery.executors.celery_executor.log"]], "module": [[0, "module-airflow.providers.celery.executors.celery_executor"], [1, "module-airflow.providers.celery.executors.celery_executor_utils"], [2, "module-airflow.providers.celery.executors.celery_kubernetes_executor"], [3, "module-airflow.providers.celery.executors.default_celery"], [4, "module-airflow.providers.celery.executors"], [5, "module-airflow.providers.celery"], [6, "module-airflow.providers.celery.sensors.celery_queue"], [7, "module-airflow.providers.celery.sensors"]], "start() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.start"]], "supports_ad_hoc_ti_run (airflow.providers.celery.executors.celery_executor.celeryexecutor attribute)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.supports_ad_hoc_ti_run"]], "supports_sentry (airflow.providers.celery.executors.celery_executor.celeryexecutor attribute)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.supports_sentry"]], "sync() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.sync"]], "terminate() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.terminate"]], "try_adopt_task_instances() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.try_adopt_task_instances"]], "update_all_task_states() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.update_all_task_states"]], "update_task_state() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[0, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.update_task_state"]], "bulkstatefetcher (class in airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.BulkStateFetcher"]], "celery_fetch_err_msg_header (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.CELERY_FETCH_ERR_MSG_HEADER"]], "exceptionwithtraceback (class in airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.ExceptionWithTraceback"]], "operation_timeout (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.OPERATION_TIMEOUT"]], "taskinstanceincelery (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.TaskInstanceInCelery"]], "airflow.providers.celery.executors.celery_executor_utils": [[1, "module-airflow.providers.celery.executors.celery_executor_utils"]], "app (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.app"]], "celery_app_name (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.celery_app_name"]], "celery_configuration (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.celery_configuration"]], "execute_command() (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.execute_command"]], "fetch_celery_task_state() (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.fetch_celery_task_state"]], "get_many() (airflow.providers.celery.executors.celery_executor_utils.bulkstatefetcher method)": [[1, "airflow.providers.celery.executors.celery_executor_utils.BulkStateFetcher.get_many"]], "log (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.log"]], "on_celery_import_modules() (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.on_celery_import_modules"]], "send_task_to_executor() (in module airflow.providers.celery.executors.celery_executor_utils)": [[1, "airflow.providers.celery.executors.celery_executor_utils.send_task_to_executor"]], "celerykubernetesexecutor (class in airflow.providers.celery.executors.celery_kubernetes_executor)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor"]], "airflow.providers.celery.executors.celery_kubernetes_executor": [[2, "module-airflow.providers.celery.executors.celery_kubernetes_executor"]], "callback_sink (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.callback_sink"]], "change_sensor_mode_to_reschedule (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.change_sensor_mode_to_reschedule"]], "cleanup_stuck_queued_tasks() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.cleanup_stuck_queued_tasks"]], "debug_dump() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.debug_dump"]], "end() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.end"]], "get_cli_commands() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor static method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.get_cli_commands"]], "get_event_buffer() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.get_event_buffer"]], "get_task_log() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.get_task_log"]], "has_task() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.has_task"]], "heartbeat() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.heartbeat"]], "is_local (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.is_local"]], "is_production (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.is_production"]], "is_single_threaded (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.is_single_threaded"]], "job_id (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor property)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.job_id"]], "kubernetes_queue() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.kubernetes_queue"]], "queue_command() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.queue_command"]], "queue_task_instance() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.queue_task_instance"]], "queued_tasks (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor property)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.queued_tasks"]], "running (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor property)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.running"]], "send_callback() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.send_callback"]], "serve_logs (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.serve_logs"]], "slots_available (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor property)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.slots_available"]], "start() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.start"]], "supports_ad_hoc_ti_run (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.supports_ad_hoc_ti_run"]], "supports_pickling (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.supports_pickling"]], "supports_sentry (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.supports_sentry"]], "terminate() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.terminate"]], "try_adopt_task_instances() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[2, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.try_adopt_task_instances"]], "default_celery_config (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.DEFAULT_CELERY_CONFIG"]], "airflow.providers.celery.executors.default_celery": [[3, "module-airflow.providers.celery.executors.default_celery"]], "broker_transport_options (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.broker_transport_options"]], "broker_transport_options_for_celery (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.broker_transport_options_for_celery"]], "broker_url (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.broker_url"]], "broker_use_ssl (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.broker_use_ssl"]], "celery_ssl_active (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.celery_ssl_active"]], "log (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.log"]], "result_backend (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.result_backend"]], "sentinel_kwargs (in module airflow.providers.celery.executors.default_celery)": [[3, "airflow.providers.celery.executors.default_celery.sentinel_kwargs"]], "airflow.providers.celery.executors": [[4, "module-airflow.providers.celery.executors"]], "base_version (in module airflow.providers.celery.executors)": [[4, "airflow.providers.celery.executors.base_version"]], "__version__ (in module airflow.providers.celery)": [[5, "airflow.providers.celery.__version__"]], "airflow.providers.celery": [[5, "module-airflow.providers.celery"]], "celeryqueuesensor (class in airflow.providers.celery.sensors.celery_queue)": [[6, "airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor"]], "airflow.providers.celery.sensors.celery_queue": [[6, "module-airflow.providers.celery.sensors.celery_queue"]], "poke() (airflow.providers.celery.sensors.celery_queue.celeryqueuesensor method)": [[6, "airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor.poke"]], "airflow.providers.celery.sensors": [[7, "module-airflow.providers.celery.sensors"]]}}) |