| Search.setIndex({"docnames": ["_api/airflow/providers/celery/cli/celery_command/index", "_api/airflow/providers/celery/cli/index", "_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", "celery_executor", "celery_kubernetes_executor", "changelog", "cli-ref", "commits", "configurations-ref", "index", "installing-providers-from-sources", "security"], "filenames": ["_api/airflow/providers/celery/cli/celery_command/index.rst", "_api/airflow/providers/celery/cli/index.rst", "_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", "celery_executor.rst", "celery_kubernetes_executor.rst", "changelog.rst", "cli-ref.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.cli.celery_command</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.celery.cli</span></code>", "<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>", "Celery Executor", "CeleryKubernetes Executor", "Changelog", "Celery Executor Commands", "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": {"command": [0, 2, 3, 4, 10, 12, 14, 15], "worker_process_nam": 0, "worker": [0, 2, 10, 11, 12, 14, 15], "sourc": [0, 2, 3, 4, 5, 6, 7, 8], "flower": [0, 10, 15, 16], "arg": [0, 3, 12, 14], "start": [0, 2, 3, 4, 10, 13, 15], "monitor": [0, 10], "tool": [0, 2, 14], "logger_setup_handl": 0, "logger": 0, "kwarg": [0, 3, 8], "reconfigur": 0, "remov": [0, 12, 14, 17], "ani": [0, 2, 3, 4, 8, 10, 17], "previous": [0, 2, 13, 15], "configur": [0, 4, 5, 10, 11, 12, 13, 14], "handler": 0, "log": [0, 2, 3, 4, 5, 10, 13, 14, 15], "sever": [0, 10], "error": [0, 2, 3, 12, 14, 15], "abov": [0, 15, 17], "goe": 0, "stderr": [0, 13], "lower": 0, "than": [0, 15], "stdout": [0, 13], "stop_work": 0, "send": [0, 2, 3, 4, 10, 15], "sigterm": [0, 2, 10], "3": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 13, 15, 16, 17, 18], "6": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 13, 15, 16, 17, 18], "2": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 13, 15, 16, 17, 18], "10": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 13, 15, 16, 17, 18], "dev0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "thi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "an": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "experiment": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "featur": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 13, 14, 15, 16, 17, 18], "celery_command": [1, 2, 7], "celeryexecutor": [2, 4, 10, 11, 12, 13, 14, 15], "For": [2, 3, 10, 13, 14, 15, 16, 17], "more": [2, 10, 13, 14, 15], "inform": [2, 10, 12, 13, 14, 15, 18], "how": [2, 10, 15, 17], "work": [2, 10, 12, 13, 15], "take": [2, 10, 15], "look": [2, 13, 15], "guid": [2, 17], "base_vers": [2, 6], "celery_send_err_msg_head": 2, "task": [2, 3, 4, 8, 11, 15], "taskinstanceinceleri": [2, 3], "__getattr__": 2, "name": [2, 8, 10, 14, 15], "arg_broker_api": 2, "arg_flower_hostnam": 2, "arg_flower_port": 2, "arg_flower_conf": 2, "arg_flower_url_prefix": 2, "arg_flower_basic_auth": 2, "arg_autoscal": 2, "arg_queu": 2, "arg_concurr": 2, "arg_celery_hostnam": 2, "arg_umask": 2, "arg_without_mingl": 2, "arg_without_gossip": 2, "airflow_vers": 2, "celery_cli_command_path": 2, "base": [2, 3, 4, 8, 11, 15], "base_executor": [2, 4], "baseexecutor": [2, 4], "recommend": [2, 10, 11, 15, 17], "product": 2, "us": [2, 3, 4, 10, 12, 13, 14, 15, 16, 17, 18], "It": [2, 4, 10, 12, 17], "allow": [2, 11, 12, 14, 15], "distribut": [2, 17], "execut": [2, 3, 4, 11, 15], "instanc": [2, 4, 15], "multipl": [2, 10, 13, 15], "node": [2, 13], "simpl": 2, "flexibl": 2, "reliabl": 2, "system": [2, 10], "process": [2, 3, 13, 14, 15], "vast": 2, "amount": 2, "messag": [2, 15], "while": [2, 15], "oper": [2, 10, 14, 15], "requir": [2, 10, 11, 12, 15, 18], "maintain": 2, "supports_ad_hoc_ti_run": [2, 4], "bool": [2, 4], "true": [2, 4, 15], "supports_sentri": [2, 4], "mai": [2, 14], "need": [2, 10, 11, 15, 16], "get": [2, 3, 10, 12, 14, 15, 17, 18], "thing": 2, "sync": [2, 10, 15], "call": [2, 3, 4, 12, 14], "period": [2, 10], "heartbeat": [2, 4], "method": [2, 3], "should": [2, 10, 11, 12, 14, 17, 18], "overrid": [2, 8, 15], "perform": [2, 10, 15], "gather": 2, "status": 2, "debug_dump": [2, 4], "debug": [2, 4], "dump": [2, 4], "respons": [2, 4, 10], "sigusr2": [2, 4], "schedul": [2, 4, 8, 10, 11, 15], "update_all_task_st": 2, "updat": [2, 12, 14, 15], "state": [2, 3, 8, 12, 14, 15], "change_st": 2, "kei": [2, 3, 15, 17], "info": [2, 3, 12], "none": [2, 3, 4, 8, 15, 17], "chang": [2, 10, 14, 18], "paramet": [2, 3, 4, 8, 10, 11, 13, 15], "model": [2, 4, 18], "taskinstancekei": [2, 4], "uniqu": 2, "util": [2, 3, 4], "taskinstancest": [2, 12, 14], "set": [2, 4, 10, 11, 13, 15], "update_task_st": [2, 12], "singl": [2, 10, 13], "end": [2, 4, 10], "synchron": [2, 10, 13, 14], "fals": [2, 4, 13, 15], "wait": [2, 8, 10, 15], "submit": 2, "job": [2, 4, 15], "complet": [2, 10, 12], "termin": [2, 4], "when": [2, 4, 8, 10, 12, 13, 14, 15, 16, 18], "daemon": [2, 13], "receiv": [2, 18], "try_adopt_task_inst": [2, 4], "ti": [2, 4], "try": [2, 4, 10, 12, 14], "adopt": [2, 4, 15], "run": [2, 3, 4, 10, 11, 12, 13, 15, 17], "have": [2, 3, 4, 8, 10, 11, 12, 13, 18], "been": [2, 4, 15], "abandon": [2, 4], "schedulerjob": [2, 4, 15], "dy": [2, 4], "anyth": [2, 4], "clear": [2, 4], "becom": [2, 4, 10], "elig": [2, 4], "re": [2, 4, 14, 15], "return": [2, 3, 4], "taskinst": [2, 4], "were": [2, 4, 13, 15], "unabl": [2, 4, 15], "type": [2, 3, 4, 12, 14, 15], "sequenc": [2, 4, 10], "cleanup_stuck_queued_task": [2, 4], "handl": [2, 10, 11], "remnant": 2, "fail": [2, 15], "becaus": [2, 10], "thei": [2, 10, 13], "stuck": 2, "queu": [2, 4], "can": [2, 3, 4, 10, 11, 12, 15, 16, 17, 18], "If": [2, 3, 10, 12, 15, 17], "detect": 2, "mark": [2, 15], "up_for_retri": 2, "ha": [2, 10, 12, 15], "remain": [2, 14], "retri": [2, 15], "doesn": [2, 3], "t": [2, 3, 12, 13, 14, 15], "list": [2, 4, 13, 14, 15], "clean": 2, "up": [2, 10, 11, 13, 14, 15], "readabl": 2, "warn": [2, 12, 14, 17], "str": [2, 3, 4, 8, 14], "static": [2, 4], "get_cli_command": [2, 4], "vend": [2, 12, 14], "cli": [2, 7, 10, 12, 13, 14], "includ": [2, 14, 15, 16, 18], "expos": 2, "via": [2, 4, 15, 16, 17], "manag": [2, 10, 12, 14, 17], "setup": [2, 10, 14], "teardown": 2, "inspect": 2, "etc": [2, 10], "make": [2, 10, 12, 13, 14, 15], "sure": [2, 10, 15], "choos": [2, 4, 17], "those": [2, 16, 17], "avoid": 2, "collis": 2, "much": 3, "code": [3, 10, 14, 17], "expens": 3, "import": [3, 12, 14, 15, 17], "load": [3, 11, 12, 14, 15], "care": 3, "where": [3, 10, 15, 18], "operation_timeout": 3, "celery_fetch_err_msg_head": 3, "fetch": [3, 4, 10], "celery_configur": 3, "app": [3, 15], "on_celery_import_modul": 3, "preload": 3, "some": [3, 10, 12, 14, 15], "onc": [3, 17], "so": [3, 4, 10, 13, 15, 18], "other": [3, 10, 13], "won": [3, 15], "again": [3, 10], "each": [3, 10], "add": [3, 12, 14], "5": [3, 10, 16], "per": [3, 14], "befor": [3, 14, 15], "long": [3, 15], "matter": 3, "short": 3, "notic": 3, "impact": 3, "execute_command": [3, 10], "command_to_exec": 3, "exceptionwithtraceback": 3, "except": [3, 12, 14, 18], "exception_traceback": 3, "wrapper": [3, 4], "propag": 3, "parent": 3, "from": [3, 4, 10, 12, 13, 14, 16, 18], "subprocess": 3, "baseexcept": [3, 12, 14], "The": [3, 8, 10, 11, 12, 13, 15, 16, 17, 18], "wrap": 3, "stacktrac": 3, "send_task_to_executor": [3, 15], "task_tupl": 3, "fetch_celery_task_st": [3, 15], "async_result": 3, "given": [3, 10, 11], "scope": [3, 18], "global": 3, "pool": [3, 4], "result": [3, 10, 15], "asyncresult": 3, "tupl": 3, "async": 3, "object": 3, "": [3, 10, 11, 13, 14, 15, 17], "bulkstatefetch": 3, "sync_parallel": 3, "logging_mixin": [3, 4], "loggingmixin": [3, 4], "statu": [3, 10, 15], "mani": [3, 10, 15], "best": 3, "avail": [3, 10, 12, 13, 15, 17], "basekeyvaluestorebackend": 3, "backend": [3, 10, 14, 15], "mget": 3, "databasebackend": 3, "select": [3, 4, 17], "task_id": 3, "IN": 3, "queri": [3, 10, 12, 14], "otherwis": [3, 4, 12, 15], "multiprocess": 3, "download": [3, 17], "individu": 3, "get_mani": 3, "celerykubernetesexecutor": [4, 12, 15], "celery_executor": [4, 6, 7, 15], "kubernetes_executor": 4, "consist": [4, 10], "kubernetesexecutor": [4, 11, 15], "queue": [4, 8, 11, 13, 15], "defin": [4, 10, 15], "valu": [4, 15], "kubernetes_queu": 4, "section": [4, 10], "default": [4, 5, 8, 10, 12, 13, 14, 15, 18], "kubernet": [4, 11, 12, 14, 15, 16], "properti": 4, "queued_task": 4, "dict": [4, 5], "queuedtaskinstancetyp": 4, "job_id": 4, "int": 4, "inherit": [4, 11, 12, 14], "attribut": [4, 10], "sinc": [4, 15], "realli": 4, "we": [4, 11, 18], "implement": [4, 14, 15], "custom": 4, "setter": 4, "slots_avail": 4, "number": [4, 10, 11, 13, 14, 15], "new": [4, 10, 14, 15, 18], "accept": [4, 13, 15], "supports_pickl": 4, "is_loc": 4, "is_single_thread": 4, "is_product": 4, "serve_log": 4, "change_sensor_mode_to_reschedul": 4, "callback_sink": 4, "callback": 4, "base_callback_sink": 4, "basecallbacksink": 4, "queue_command": 4, "task_inst": 4, "prioriti": 4, "1": [4, 10, 15, 16], "queue_task_inst": 4, "mark_success": 4, "pickle_id": 4, "ignore_all_dep": 4, "ignore_depends_on_past": 4, "wait_for_past_depends_before_skip": 4, "ignore_task_dep": 4, "ignore_ti_st": 4, "cfg_path": 4, "get_task_log": 4, "try_numb": 4, "has_task": 4, "check": [4, 8, 12, 14, 15, 17], "either": [4, 10], "known": 4, "sent": [4, 10], "trigger": 4, "get_event_buff": 4, "dag_id": 4, "flush": 4, "event": [4, 13], "buffer": 4, "all": [4, 10, 12, 14, 15, 16, 18], "eventbuffervaluetyp": 4, "send_callback": 4, "request": 4, "callback_request": 4, "callbackrequest": 4, "broker_url": 5, "broker_transport_opt": [5, 15], "sentinel_kwarg": [5, 12, 14], "result_backend": 5, "default_celery_config": [5, 15], "celery_ssl_act": 5, "broker_use_ssl": 5, "match_not_recommended_backend": 5, "celery_executor_util": [6, 7], "celery_kubernetes_executor": [6, 7], "default_celeri": [6, 7, 12, 14, 15], "executor": [7, 12, 14, 15], "sensor": [7, 12, 14], "celery_queu": [7, 9], "__version__": [7, 14], "celeryqueuesensor": 8, "target_task_id": 8, "basesensoroper": 8, "empti": 8, "By": [8, 17], "order": [8, 12, 16], "consid": [8, 11], "must": [8, 10], "reserv": 8, "activ": 8, "id": [8, 17], "poke": 8, "context": [8, 10, 12, 14], "deriv": 8, "As": [10, 11], "airflow": [10, 11, 12, 13, 15, 17, 18], "7": [10, 11, 12, 13, 14, 15], "you": [10, 11, 12, 13, 15, 16, 17, 18], "instal": [10, 11, 12, 14, 18], "provid": [10, 11, 12, 13, 15, 17, 18], "packag": [10, 11, 12, 15], "done": [10, 11, 18], "apach": [10, 11, 12, 13, 15, 17], "extra": [10, 11, 12, 14, 16], "pip": [10, 11, 12, 14, 16, 17], "one": [10, 15, 17], "wai": 10, "scale": [10, 11], "out": [10, 14, 15, 18], "rabbitmq": [10, 15], "redi": [10, 12, 14, 15, 16], "sentinel": [10, 15], "depend": [10, 12, 14, 15, 18], "librabbitmq": 10, "your": [10, 11, 12, 15], "cfg": [10, 15], "point": [10, 14], "relat": 10, "about": [10, 12, 14, 17, 18], "broker": [10, 12, 13, 15], "refer": [10, 11], "exhaust": 10, "document": [10, 12, 13, 14, 15], "topic": 10, "found": [10, 11, 18], "here": 10, "ar": [10, 13, 15, 16, 17, 18], "few": 10, "imper": 10, "path": [10, 15], "homogen": 10, "across": 10, "cluster": [10, 11], "met": 10, "exampl": [10, 13, 15, 16, 17], "hiveoper": 10, "hive": 10, "box": [10, 15], "mysqloper": 10, "python": [10, 12, 14, 16, 17], "librari": 10, "pythonpath": 10, "somehow": 10, "access": 10, "its": [10, 15], "dags_fold": 10, "filesystem": 10, "own": [10, 12, 14], "mean": [10, 15], "A": [10, 11, 13, 14, 15], "common": [10, 14], "would": 10, "store": 10, "git": 10, "repositori": 10, "machin": [10, 13], "chef": 10, "puppet": 10, "ansibl": 10, "whatev": 10, "environ": [10, 11, 15], "mount": 10, "pipelin": 10, "file": [10, 12, 13, 14, 15, 17], "share": 10, "well": [10, 17], "To": [10, 17], "kick": 10, "off": 10, "subcommand": 10, "pick": [10, 15, 18], "soon": 10, "fire": 10, "direct": [10, 12, 14], "stop": 10, "gracefulli": [10, 13], "signal": 10, "main": [10, 17, 18], "note": [10, 12, 14], "also": [10, 11, 12, 15, 17], "web": 10, "ui": [10, 15], "built": 10, "top": [10, 16, 17], "shortcut": [10, 15], "server": [10, 13, 15, 17], "pleas": [10, 17], "alreadi": [10, 15, 17], "bundl": 10, "caveat": 10, "databas": [10, 15], "back": 10, "visibl": [10, 15], "timeout": [10, 15], "celery_broker_transport_opt": 10, "exce": [10, 11, 15], "eta": [10, 15], "longest": [10, 15], "specifi": [10, 15, 16], "password": [10, 13, 15], "protect": [10, 15], "umask": [10, 13], "worker_umask": 10, "permiss": 10, "newli": 10, "creat": [10, 15, 17], "consum": 10, "resourc": [10, 11, 15], "enough": 10, "worker_concurr": 10, "limit": [10, 12, 14, 15], "256": 10, "charact": 10, "might": [10, 16, 18], "restrict": 10, "see": [10, 13, 14, 15, 16], "modul": [10, 12, 14], "detail": [10, 14, 17], "compon": [10, 13], "assign": [10, 15], "ad": [10, 12, 14], "necessari": [10, 15], "http": [10, 13, 15, 17], "dag": 10, "contain": [10, 15, 17], "variabl": [10, 15], "connect": [10, 15], "mechan": [10, 14], "two": 10, "commun": 10, "place": 10, "reveal": 10, "structur": [10, 14], "4": [10, 11], "xcom": 10, "save": 10, "8": [10, 12, 14], "9": 10, "11": [10, 14, 17], "put": 10, "diagram": 10, "initi": [10, 12], "schedulerprocess": 10, "workerprocess": 10, "observ": 10, "appear": 10, "workerchildprocess": 10, "queuebrok": 10, "resultbackend": 10, "dure": 10, "localtaskjobprocess": 10, "logic": [10, 12, 14], "describ": [10, 15, 17], "localtaskjob": 10, "rawtaskprocess": 10, "taskrunn": 10, "user": [10, 11, 13, 15, 17], "e": 10, "g": 10, "find": 10, "begin": 10, "awar": 10, "proper": 10, "function": 10, "class": [10, 12, 14, 16], "finish": [10, 15], "12": [10, 14, 15, 17], "notifi": 10, "subsequ": 10, "13": [10, 14], "ask": 10, "baseoper": 10, "default_queu": 10, "which": [10, 13, 15, 18], "listen": 10, "comma": [10, 13, 15], "delimit": [10, 13], "whitespac": 10, "q": [10, 13], "spark": 10, "quark": 10, "onli": [10, 11, 12, 13, 15, 18], "wire": 10, "special": 10, "perspect": 10, "sai": 10, "veri": 10, "lightweight": 10, "could": 10, "thousand": 10, "without": [10, 13], "problem": 10, "want": [10, 12, 17, 18], "within": 10, "itself": [10, 18], "specif": [10, 14], "secur": [10, 13, 15], "right": [10, 12], "both": 11, "celeri": [11, 12, 17], "cncf": [11, 12, 14, 16], "simultan": 11, "chosen": 11, "scalabl": 11, "high": [11, 14], "peak": 11, "time": [11, 15], "runtim": 11, "isol": 11, "certain": 11, "case": [11, 15, 18], "meet": 11, "comfort": 11, "rel": 11, "small": 11, "portion": 11, "plenti": 11, "hungri": 11, "better": 11, "predefin": 11, "ensur": [12, 14], "__exit__": [12, 14], "decor": [12, 14], "38383": [12, 14], "don": [12, 13, 14], "dispos": [12, 14], "sqlalchemi": [12, 14, 15], "engin": [12, 14, 15], "intern": [12, 14], "api": [12, 13, 14], "38562": [12, 14], "38879": [12, 14], "38385": [12, 14], "rerais": 12, "airflowoptionalproviderfeatureexcept": [12, 14], "38555": [12, 14], "pid": [12, 13, 14], "option": [12, 14, 15], "duplic": [12, 14], "issu": [12, 14], "move": [12, 14, 15], "36794": [12, 14], "airflowtasktimeout": [12, 14, 15], "35653": [12, 14], "migrat": [12, 14], "doc": [12, 13, 14, 15], "respect": [12, 14], "37728": [12, 14], "task_acks_l": [12, 14], "37066": [12, 14], "improv": [12, 14, 15], "prevent": [12, 14, 15], "autoscal": [12, 13, 14, 15], "misconfig": [12, 14], "36576": [12, 14], "stacklevel": [12, 14], "36831": [12, 14], "env": [12, 14], "36318": [12, 14], "releas": [12, 14, 16], "explain": 12, "support": [12, 14, 15, 16], "polici": [12, 18], "bump": [12, 14], "minimum": [12, 13, 14, 15, 16], "version": [12, 14, 15, 16, 17, 18], "36017": [12, 14], "_secret": 12, "_cmd": 12, "34782": [12, 14], "sensit": [12, 14], "34954": [12, 14], "min": [12, 14], "34728": [12, 14], "soft_fail": [12, 14], "argument": [12, 14], "rais": [12, 14], "34474": [12, 14], "condit": 12, "34192": [12, 14], "combin": [12, 14], "similar": [12, 14], "33987": [12, 14], "exclud": [12, 14], "34031": [12, 14], "replac": [12, 14], "pass": [12, 14, 15], "contextlib": [12, 14], "suppress": [12, 14], "33980": [12, 14], "them": [12, 14, 16], "block": [12, 14, 15], "33754": [12, 14], "opentelemetri": [12, 14], "33579": [12, 14], "auth": [12, 13, 14], "33481": [12, 14], "refactor": [12, 14], "style": [12, 14], "part": [12, 13, 14], "32883": [12, 14], "miss": [12, 14], "re2": [12, 14, 16], "33237": [12, 14], "32627": [12, 14], "gener": [12, 14], "33081": [12, 14], "rid": [12, 14], "python2": [12, 14], "numer": [12, 14], "relic": [12, 14], "33050": [12, 14], "first": 12, "core": [12, 13, 14, 15], "expect": 12, "32526": [12, 14], "pre": [12, 14], "hardcod": [12, 14], "config": [12, 14], "older": [12, 14, 18], "32775": [12, 14], "aip": [12, 14], "51": [12, 14], "29055": [12, 14], "k8": [12, 14], "32767": [12, 14], "discoveri": [12, 14], "32532": [12, 14], "py": [12, 14], "insid": [12, 14], "32628": [12, 14], "origin": [12, 14, 15, 17], "32931": [12, 14], "drop": [12, 14, 17], "32015": [12, 14], "30917": [12, 14], "27196": [12, 14], "our": [12, 14], "approach": [12, 14], "bound": [12, 14], "22573": [12, 14], "mistakenli": 12, "install_requir": 12, "22382": 12, "trove": 12, "classifi": [12, 14], "pypi": [12, 14, 16, 18], "framework": 12, "convert": 12, "follow": [12, 17, 18], "auto": [12, 14], "appli": [12, 14, 15], "apply_default": [12, 14], "15667": [12, 14], "due": [12, 15], "upgrad": [12, 14, 18], "least": 12, "automat": 12, "manual": 12, "db": [12, 15], "readm": [12, 14], "below": [13, 15, 16, 17], "usag": [13, 14], "h": 13, "group_or_command": 13, "possibl": 13, "choic": [13, 15], "org": [13, 17], "stabl": [13, 15], "html": [13, 15], "basic_auth": 13, "broker_api": 13, "d": [13, 17], "c": 13, "flower_conf": 13, "hostnam": 13, "l": [13, 17], "log_fil": 13, "p": 13, "port": [13, 15], "u": 13, "url_prefix": 13, "v": 13, "basic": [13, 15], "authent": [13, 15], "pair": [13, 15], "separ": [13, 14, 15, 18], "flower_basic_auth": 13, "user1": [13, 15], "password1": [13, 15], "user2": [13, 15], "password2": [13, 15], "instead": 13, "foreground": 13, "conf": 13, "locat": 13, "5555": [13, 15], "redirect": 13, "url": [13, 15], "prefix": [13, 15], "verbos": 13, "output": 13, "celery_hostnam": 13, "concurr": [13, 15], "gossip": 13, "mingl": 13, "maximum": [13, 15], "16": [13, 14, 15], "serv": 13, "skip": 13, "along": 13, "mode": [13, 15], "subscrib": 13, "commit": 14, "level": 14, "changelog": 14, "latest": [14, 15, 18], "2024": 14, "04": 14, "09": 14, "subject": 14, "3e30b3a025": 14, "179b963782": 14, "03": 14, "27": 14, "2ad923a001": 14, "rerai": 14, "6296f7e224": 14, "22": 14, "095c5fe313": 14, "21": 14, "0a74928894": 14, "18": 14, "ruff": 14, "38240": 14, "83316b8158": 14, "prepar": [14, 18], "1st": 14, "wave": 14, "rc1": 14, "march": 14, "37876": 14, "a7d13315e1": 14, "02": 14, "resolv": 14, "g003": 14, "statement": 14, "37848": 14, "cd33c2a6a7": 14, "8d74ee8dcd": 14, "25": 14, "fix": [14, 18], "581e2e42e9": 14, "5a0be392e6": 14, "comment": 14, "37488": 14, "bfb054e9e8": 14, "februari": 14, "37326": 14, "6c72223f86": 14, "06": 14, "4fa8e45c92": 14, "01": 14, "28": 14, "26": 14, "cead3da4a6": 14, "rc2": 14, "2nd": 14, "round": 14, "jan": 14, "37019": 14, "2b4da0101f": 14, "januari": 14, "36945": 14, "6ff96af480": 14, "c439ab87c4": 14, "standard": 14, "build": [14, 17], "switch": 14, "hatchl": 14, "36537": 14, "19ebcac239": 14, "07": 14, "36640": 14, "6937ae7647": 14, "2023": 14, "30": 14, "speed": 14, "autocomplet": 14, "breez": 14, "simplifi": 14, "36499": 14, "23": 14, "b15d5578da": 14, "decemb": 14, "36380": 14, "f5883d6e7b": 14, "36373": 14, "e2393ee6dd": 14, "20": 14, "08": 14, "999b70178a": 14, "36112": 14, "d0918d77ee": 14, "c905fe88d": 14, "link": [14, 17], "yaml": 14, "35837": 14, "0b23d5601c": 14, "24": 14, "novemb": 14, "35836": 14, "99534e47f3": 14, "19": 14, "reproduc": 14, "35693": 14, "99df205f42": 14, "reappli": 14, "templat": 14, "35686": 14, "1b059c57d6": 14, "35537": 14, "d1c58d86de": 14, "3rd": 14, "octob": 14, "35233": 14, "3592ff4046": 14, "35187": 14, "dd7ba3cae1": 14, "292": 14, "35053": 14, "39e611b43b": 14, "35020": 14, "1ae9279346": 14, "17": 14, "init": 14, "f23170c9dd": 14, "d401": 14, "thru": 14, "inclus": 14, "34934": 14, "dd59e3e63": 14, "15": 14, "e9987d5059": 14, "34916": 14, "0c8e30e43b": 14, "05": 14, "7ebf4220c9": 14, "34320": 14, "f19e055789": 14, "21990ed894": 14, "34201": 14, "50cccbdf44": 14, "bad": 14, "cleanup": 14, "fa5e54c4c5": 14, "b6318ffabc": 14, "a9bbb430fc": 14, "9d8c77e447": 14, "c077d19060": 14, "aug": 14, "33730": 14, "b1a3b42880": 14, "ae25a52ae3": 14, "4c4981d1ad": 14, "b5a4d36383": 14, "33291": 14, "0b528e2b2": 14, "9556d6d5f6": 14, "60677b0ba3": 14, "33128": 14, "879fd34e97": 14, "e3d82c6be0": 14, "29": 14, "d06b7af69a": 14, "juli": 14, "32875": 14, "f31af91dbd": 14, "fcbbf47864": 14, "e93460383f": 14, "2ac237b3eb": 14, "56c41d460c": 14, "introduc": 14, "32765": 14, "73b90c48b1": 14, "contribut": 14, "32604": 14, "ea0deaa993": 14, "624211f33f": 14, "40d54eac1a": 14, "225e3041d2": 14, "32381": 14, "3878fe6fab": 14, "spuriou": 14, "header": 14, "32373": 14, "cb4927a018": 14, "32298": 14, "8c37b74a20": 14, "d205": 14, "32226": 14, "09d4718d3a": 14, "32125": 14, "79bcc2e668": 14, "june": 14, "32001": 14, "8b146152d6": 14, "45548b9451": 14, "31416": 14, "abea189022": 14, "31393": 14, "f5aed58d9f": 14, "circular": 14, "caus": 14, "31379": 14, "d9ff55cf6d": 14, "31252": 14, "eef5bc7f16": 14, "full": 14, "autom": 14, "30994": 14, "a7eb32a5b2": 14, "d23a3bbed8": 14, "suspend": 14, "30422": 14, "2022": 14, "12c3c39d1a": 14, "27613": 14, "9ab1a6a3e7": 14, "old": 14, "26872": 14, "78b8ea2f22": 14, "2a34dc9e84": 14, "enabl": [14, 15], "string": [14, 15], "normal": 14, "format": [14, 15], "27205": 14, "f8db64c35c": 14, "septemb": 14, "26731": 14, "06acf40a43": 14, "pep": 14, "563": 14, "postpon": 14, "evalu": 14, "annot": 14, "non": 14, "26289": 14, "e5ac6c7cfb": 14, "august": 14, "25618": 14, "d2459a241b": 14, "25030": 14, "0de31bd73a": 14, "folder": [14, 17], "24672": 14, "dcdcf3a2b8": 14, "24307": 14, "717a7588bc": 14, "descript": 14, "doubl": 14, "24292": 14, "aeabe994b3": 14, "24231": 14, "027b707d21": 14, "explanatori": 14, "contributor": 14, "24229": 14, "56ab82ed7a": 14, "mid": 14, "april": 14, "22819": 14, "6db30f3207": 14, "d7dbfb7e26": 14, "bugfix": [14, 18], "22383": 14, "14": 14, "16adc035b1": 14, "22226": 14, "f5b96315fe": 14, "feb": 14, "22056": 14, "d94fa37830": 14, "delai": 14, "21439": 14, "6c3a67d4fc": 14, "2021": [14, 17], "21257": 14, "602abe8394": 14, "line": 14, "now": 14, "sphinx": 14, "autoapi": 14, "typehint": 14, "20951": 14, "f77417eb0d": 14, "31": 14, "compat": 14, "20614": 14, "97496ba2b4": 14, "20523": 14, "a0821235fb": 14, "everywher": 14, "20565": 14, "fd5d65751c": 14, "18018": 14, "bbc627a3da": 14, "16501": 14, "cbf8001d76": 14, "after": 14, "buggfix": 14, "16464": 14, "1fba5402bb": 14, "16405": 14, "9c94b72d44": 14, "16294": 14, "37681bca00": 14, "807ad32ce5": 14, "15576": 14, "40a2476a5d": 14, "interact": 14, "15518": 14, "68e4c4dcb0": 14, "backport": 14, "14886": 14, "6e6526a0f6": 14, "broken": 14, "14734": 14, "88bdcfa0df": 14, "14013": 14, "ac2f72c98d": 14, "13767": 14, "3fd5ef3555": 14, "logo": 14, "integr": 14, "13717": 14, "295d66f914": 14, "2020": 14, "grammar": 14, "13380": 14, "6cf76d7ac0": 14, "typo": 14, "13148": 14, "32971a1a2d": 14, "12955": 14, "b40dffa085": 14, "renam": 14, "rema": 14, "match": [14, 15, 17], "12917": 14, "c34ef853c8": 14, "12444": 14, "0080354502": 14, "0b2": 14, "batch": 14, "12449": 14, "ae7cb4a1e2": 14, "wrong": 14, "hash": 14, "12390": 14, "6889a333cf": 14, "hook": 14, "ref": 14, "12366": 14, "7825e8f590": 14, "12304": 14, "85a18e13d9": 14, "project": 14, "page": [14, 15, 17], "cross": 14, "12212": 14, "59eb5de78c": 14, "come": 14, "0beta1": 14, "12206": 14, "b2a28d1590": 14, "script": [14, 17], "dev": [14, 15], "12082": 14, "4e8f9cc8d0": 14, "black": 14, "formmatt": 14, "9550": 14, "8c42cf1b00": 14, "pyupgrad": 14, "11447": 14, "5a439e84eb": 14, "2a1": 14, "11855": 14, "872b1566a1": 14, "11826": 14, "16e7129719": 14, "11487": 14, "0a0e1af800": 14, "markdown": 14, "toc": 14, "11249": 14, "ca4238eb4d": 14, "month": 14, "11242": 14, "5220e4c384": 14, "11238": 14, "fdd9b6f65b": 14, "10543": 14, "3696c34c28": 14, "word": 14, "10528": 14, "ee7ca128a1": 14, "refernc": 14, "10483": 14, "cdec301254": 14, "correct": [14, 17], "signatur": [14, 16, 17], "10205": 14, "24c8e4c2d6": 14, "constructor": 14, "10163": 14, "5bb228d841": 14, "hint": 14, "9762": 14, "d0e7db4024": 14, "fresh": 14, "9408": 14, "12af6a0800": 14, "final": 14, "23rc1": 14, "9404": 14, "c7e5bce57f": 14, "candid": 14, "9370": 14, "f6bd817a3a": 14, "transfer": 14, "9320": 14, "0b0e4f7a4c": 14, "rc3": 14, "relas": 14, "9026": 14, "00642a46d0": 14, "wrongli": 14, "8994": 14, "375d1ca229": 14, "8898": 14, "12c5e5d8a": 14, "8891": 14, "f3521fb0e3": 14, "regener": 14, "8886": 14, "92585ca4cb": 14, "8807": 14, "97a429f9d0": 14, "6714": 14, "magic": 14, "utf": 14, "7338": 14, "059eda05f8": 14, "6610": 14, "softwar": [14, 17], "7231": 14, "embed": 15, "wa": 15, "6379": 15, "airflow__celery__broker_url": 15, "airflow__celery__broker_url_cmd": 15, "airflow__celery__broker_url_secret": 15, "airflow__celery__celery_app_nam": 15, "airflow__celery__celery_config_opt": 15, "airflow__celery__flower_basic_auth": 15, "airflow__celery__flower_basic_auth_cmd": 15, "airflow__celery__flower_basic_auth_secret": 15, "sweet": 15, "ip": 15, "airflow__celery__flower_host": 15, "airflow__celery__flower_port": 15, "root": 15, "airflow__celery__flower_url_prefix": 15, "second": 15, "float": 15, "airflow__celery__operation_timeout": 15, "prefork": 15, "eventlet": 15, "gevent": 15, "solo": 15, "celeryq": 15, "en": 15, "userguid": 15, "airflow__celery__pool": 15, "metadata": 15, "therefor": 15, "post": 15, "bu": 15, "insert": 15, "highli": 15, "sql_alchemy_conn": 15, "scheme": 15, "airflow__celery__result_backend": 15, "airflow__celery__result_backend_cmd": 15, "airflow__celery__result_backend_secret": 15, "postgresql": 15, "postgr": 15, "dictionari": 15, "airflow__celery__result_backend_sqlalchemy_engine_opt": 15, "pool_recycl": 15, "1800": 15, "airflow__celery__ssl_act": 15, "ca": 15, "certif": [15, 17], "airflow__celery__ssl_cacert": 15, "client": 15, "airflow__celery__ssl_cert": 15, "airflow__celery__ssl_kei": 15, "max": 15, "airflow__celery__sync_parallel": 15, "even": 15, "still": 15, "successfulli": 15, "show": 15, "Not": 15, "forc": 15, "until": 15, "effect": 15, "acks_lat": 15, "boolean": 15, "airflow__celery__task_acks_l": 15, "publish": [15, 18], "give": 15, "integ": 15, "airflow__celery__task_publish_max_retri": 15, "report": 15, "keep": 15, "track": 15, "restart": 15, "orphan": 15, "launch": 15, "previou": [15, 17], "airflow__celery__task_track_start": 15, "dynam": 15, "resiz": 15, "autosc": 15, "max_concurr": 15, "min_concurr": 15, "alwai": [15, 18], "grow": 15, "natur": 15, "ignor": 15, "bin": [15, 17], "cmdoption": 15, "airflow__celery__worker_autoscal": 15, "size": 15, "airflow__celery__worker_concurr": 15, "remot": 15, "control": 15, "In": 15, "doe": 15, "lot": 15, "repli": 15, "pidbox": 15, "howev": 15, "disabl": 15, "index": 15, "overview": 15, "airflow__celery__worker_enable_remote_control": 15, "initialis": 15, "valid": [15, 17], "airflow__celery__worker_precheck": 15, "increas": 15, "prefetch": 15, "multipli": 15, "greater": 15, "being": 15, "unnecessarili": 15, "sit": 15, "behind": 15, "anoth": 15, "unutil": 15, "claim": 15, "optim": 15, "airflow__celery__worker_prefetch_multipli": 15, "task_queued_timeout": 15, "underli": 15, "transport": 15, "std": 15, "addit": 15, "typic": 15, "scenario": 15, "through": 15, "although": 15, "conform": 15, "airflow__celery_broker_transport_options__sentinel_kwarg": 15, "airflow__celery_broker_transport_options__sentinel_kwargs_cmd": 15, "airflow__celery_broker_transport_options__sentinel_kwargs_secret": 15, "password_for_redis_serv": 15, "acknowledg": 15, "redeliv": 15, "plan": 15, "sq": 15, "airflow__celery_broker_transport_options__visibility_timeout": 15, "21600": 15, "airflow__celery_kubernetes_executor__kubernetes_queu": 15, "exist": 16, "googl": 16, "verifi": 16, "checksum": [16, 17], "site": 16, "sdist": [16, 17], "asc": [16, 17], "sha512": [16, 17], "wheel": 16, "offici": 17, "most": 17, "differ": 17, "down": 17, "left": 17, "whl": 17, "foundat": 17, "pgp": 17, "essenti": 17, "sha": 17, "gpg": 17, "relev": 17, "directori": 17, "mirror": 17, "pgpk": 17, "ka": 17, "binari": 17, "pgpv": 17, "tar": 17, "gz": 17, "made": 17, "sat": 17, "sep": 17, "49": 17, "54": 17, "bst": 17, "rsa": 17, "cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f": 17, "issuer": 17, "kaxilnaik": 17, "good": [17, 18], "kaxil": 17, "naik": 17, "unknown": 17, "aka": 17, "gmail": 17, "com": 17, "certifi": 17, "trust": 17, "There": 17, "indic": 17, "belong": 17, "owner": 17, "primari": 17, "fingerprint": 17, "cde1": 17, "5c6e": 17, "4d3a": 17, "8ec4": 17, "ecf4": 17, "ba4b": 17, "6674": 17, "e08a": 17, "d7de": 17, "406f": 17, "do": 17, "worri": 17, "self": 17, "sign": 17, "why": 17, "step": 17, "know": 17, "sum": 17, "shasum": 17, "512": 17, "diff": 17, "local": 17, "bash": 17, "package_vers": 17, "package_nam": 17, "provider_download_dir": 17, "mktemp": 17, "dep": 17, "dest": 17, "curl": 17, "apache_airflow_providers_celeri": 17, "py3": 17, "o": 17, "echo": 17, "la": 17, "instruct": [17, 18], "chapter": 17, "temporari": 17, "independ": 18, "vulner": 18, "develop": 18, "branch": 18, "next": 18, "strict": 18, "semver": 18, "major": 18, "break": 18, "minor": 18, "patchlevel": 18, "bug": 18, "rule": 18, "critic": 18, "reason": 18, "band": 18, "stakehold": 18, "decid": 18, "cherri": 18, "mix": 18, "govern": 18, "interest": 18, "parti": 18, "test": 18}, "objects": {"airflow.providers": [[7, 0, 0, "-", "celery"]], "airflow.providers.celery": [[7, 1, 1, "", "__version__"], [1, 0, 0, "-", "cli"], [6, 0, 0, "-", "executors"], [9, 0, 0, "-", "sensors"]], "airflow.providers.celery.cli": [[0, 0, 0, "-", "celery_command"]], "airflow.providers.celery.cli.celery_command": [[0, 1, 1, "", "WORKER_PROCESS_NAME"], [0, 2, 1, "", "flower"], [0, 2, 1, "", "logger_setup_handler"], [0, 2, 1, "", "stop_worker"], [0, 2, 1, "", "worker"]], "airflow.providers.celery.executors": [[6, 1, 1, "", "base_version"], [2, 0, 0, "-", "celery_executor"], [3, 0, 0, "-", "celery_executor_utils"], [4, 0, 0, "-", "celery_kubernetes_executor"], [5, 0, 0, "-", "default_celery"]], "airflow.providers.celery.executors.celery_executor": [[2, 1, 1, "", "AIRFLOW_VERSION"], [2, 1, 1, "", "ARG_AUTOSCALE"], [2, 1, 1, "", "ARG_BROKER_API"], [2, 1, 1, "", "ARG_CELERY_HOSTNAME"], [2, 1, 1, "", "ARG_CONCURRENCY"], [2, 1, 1, "", "ARG_FLOWER_BASIC_AUTH"], [2, 1, 1, "", "ARG_FLOWER_CONF"], [2, 1, 1, "", "ARG_FLOWER_HOSTNAME"], [2, 1, 1, "", "ARG_FLOWER_PORT"], [2, 1, 1, "", "ARG_FLOWER_URL_PREFIX"], [2, 1, 1, "", "ARG_QUEUES"], [2, 1, 1, "", "ARG_UMASK"], [2, 1, 1, "", "ARG_WITHOUT_GOSSIP"], [2, 1, 1, "", "ARG_WITHOUT_MINGLE"], [2, 1, 1, "", "CELERY_CLI_COMMAND_PATH"], [2, 1, 1, "", "CELERY_COMMANDS"], [2, 1, 1, "", "CELERY_SEND_ERR_MSG_HEADER"], [2, 3, 1, "", "CeleryExecutor"], [2, 1, 1, "", "TaskInstanceInCelery"], [2, 2, 1, "", "__getattr__"], [2, 1, 1, "", "base_version"], [2, 1, 1, "", "log"]], "airflow.providers.celery.executors.celery_executor.CeleryExecutor": [[2, 4, 1, "", "change_state"], [2, 4, 1, "", "cleanup_stuck_queued_tasks"], [2, 4, 1, "", "debug_dump"], [2, 4, 1, "", "end"], [2, 4, 1, "", "get_cli_commands"], [2, 4, 1, "", "start"], [2, 5, 1, "", "supports_ad_hoc_ti_run"], [2, 5, 1, "", "supports_sentry"], [2, 4, 1, "", "sync"], [2, 4, 1, "", "terminate"], [2, 4, 1, "", "try_adopt_task_instances"], [2, 4, 1, "", "update_all_task_states"], [2, 4, 1, "", "update_task_state"]], "airflow.providers.celery.executors.celery_executor_utils": [[3, 3, 1, "", "BulkStateFetcher"], [3, 1, 1, "", "CELERY_FETCH_ERR_MSG_HEADER"], [3, 3, 1, "", "ExceptionWithTraceback"], [3, 1, 1, "", "OPERATION_TIMEOUT"], [3, 1, 1, "", "TaskInstanceInCelery"], [3, 1, 1, "", "app"], [3, 1, 1, "", "celery_configuration"], [3, 2, 1, "", "execute_command"], [3, 2, 1, "", "fetch_celery_task_state"], [3, 1, 1, "", "log"], [3, 2, 1, "", "on_celery_import_modules"], [3, 2, 1, "", "send_task_to_executor"]], "airflow.providers.celery.executors.celery_executor_utils.BulkStateFetcher": [[3, 4, 1, "", "get_many"]], "airflow.providers.celery.executors.celery_kubernetes_executor": [[4, 3, 1, "", "CeleryKubernetesExecutor"]], "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor": [[4, 5, 1, "", "callback_sink"], [4, 5, 1, "", "change_sensor_mode_to_reschedule"], [4, 4, 1, "", "cleanup_stuck_queued_tasks"], [4, 4, 1, "", "debug_dump"], [4, 4, 1, "", "end"], [4, 4, 1, "", "get_cli_commands"], [4, 4, 1, "", "get_event_buffer"], [4, 4, 1, "", "get_task_log"], [4, 4, 1, "", "has_task"], [4, 4, 1, "", "heartbeat"], [4, 5, 1, "", "is_local"], [4, 5, 1, "", "is_production"], [4, 5, 1, "", "is_single_threaded"], [4, 6, 1, "", "job_id"], [4, 4, 1, "", "kubernetes_queue"], [4, 4, 1, "", "queue_command"], [4, 4, 1, "", "queue_task_instance"], [4, 6, 1, "", "queued_tasks"], [4, 6, 1, "", "running"], [4, 4, 1, "", "send_callback"], [4, 5, 1, "", "serve_logs"], [4, 6, 1, "", "slots_available"], [4, 4, 1, "", "start"], [4, 5, 1, "", "supports_ad_hoc_ti_run"], [4, 5, 1, "", "supports_pickling"], [4, 5, 1, "", "supports_sentry"], [4, 4, 1, "", "terminate"], [4, 4, 1, "", "try_adopt_task_instances"]], "airflow.providers.celery.executors.default_celery": [[5, 1, 1, "", "DEFAULT_CELERY_CONFIG"], [5, 1, 1, "", "broker_transport_options"], [5, 1, 1, "", "broker_url"], [5, 1, 1, "", "broker_use_ssl"], [5, 1, 1, "", "celery_ssl_active"], [5, 1, 1, "", "log"], [5, 1, 1, "", "match_not_recommended_backend"], [5, 1, 1, "", "result_backend"], [5, 1, 1, "", "sentinel_kwargs"]], "airflow.providers.celery.sensors": [[8, 0, 0, "-", "celery_queue"]], "airflow.providers.celery.sensors.celery_queue": [[8, 3, 1, "", "CeleryQueueSensor"]], "airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor": [[8, 4, 1, "", "poke"]]}, "objtypes": {"0": "py:module", "1": "py:data", "2": "py:function", "3": "py:class", "4": "py:method", "5": "py:attribute", "6": "py:property"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "data", "Python data"], "2": ["py", "function", "Python function"], "3": ["py", "class", "Python class"], "4": ["py", "method", "Python method"], "5": ["py", "attribute", "Python attribute"], "6": ["py", "property", "Python property"]}, "titleterms": {"airflow": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 14, 16], "provid": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 14, 16], "celeri": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 13, 14, 15, 16], "cli": [0, 1], "celery_command": 0, "modul": [0, 2, 3, 4, 5, 8], "content": [0, 2, 3, 4, 5, 6, 7, 8], "function": [0, 2, 3], "attribut": [0, 2, 3], "submodul": [1, 6, 9], "executor": [2, 3, 4, 5, 6, 10, 11, 13], "celery_executor": 2, "class": [2, 3, 4, 8], "celery_executor_util": 3, "celery_kubernetes_executor": [4, 15], "default_celeri": 5, "packag": [6, 7, 14, 16, 17], "subpackag": 7, "sensor": [8, 9], "celery_queu": 8, "architectur": 10, "task": 10, "execut": 10, "process": 10, "queue": 10, "celerykubernet": 11, "when": 11, "us": 11, "celerykubernetesexecutor": 11, "changelog": 12, "3": [12, 14], "6": [12, 14], "2": [12, 14], "bug": 12, "fix": 12, "misc": 12, "1": [12, 14], "0": [12, 14], "featur": 12, "5": [12, 14], "4": [12, 14], "break": 12, "chang": 12, "command": 13, "posit": 13, "argument": 13, "sub": 13, "flower": 13, "name": 13, "stop": 13, "worker": 13, "apach": [14, 16], "configur": 15, "refer": 15, "section": 15, "broker_url": 15, "celery_app_nam": 15, "celery_config_opt": 15, "flower_basic_auth": 15, "flower_host": 15, "flower_port": 15, "flower_url_prefix": 15, "operation_timeout": 15, "pool": 15, "result_backend": 15, "result_backend_sqlalchemy_engine_opt": 15, "ssl_activ": 15, "ssl_cacert": 15, "ssl_cert": 15, "ssl_kei": 15, "sync_parallel": 15, "task_acks_l": 15, "task_publish_max_retri": 15, "task_track_start": 15, "worker_autoscal": 15, "worker_concurr": 15, "worker_enable_remote_control": 15, "worker_precheck": 15, "worker_prefetch_multipli": 15, "default_queu": 15, "deprec": 15, "stalled_task_timeout": 15, "task_adoption_timeout": 15, "worker_log_server_port": 15, "celery_broker_transport_opt": 15, "sentinel_kwarg": 15, "visibility_timeout": 15, "kubernetes_queu": 15, "instal": [16, 17], "requir": 16, "cross": 16, "depend": 16, "download": 16, "offici": 16, "from": 17, "sourc": 17, "releas": [17, 18], "integr": 17, "verifi": 17, "pypi": 17, "secur": 18, "patch": 18}, "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.cli.celery_command": [[0, "module-airflow.providers.celery.cli.celery_command"]], "Module Contents": [[0, "module-contents"], [2, "module-contents"], [3, "module-contents"], [4, "module-contents"], [5, "module-contents"], [8, "module-contents"]], "Functions": [[0, "functions"], [2, "functions"], [3, "functions"]], "Attributes": [[0, "attributes"], [2, "attributes"], [3, "attributes"]], "airflow.providers.celery.cli": [[1, "module-airflow.providers.celery.cli"]], "Submodules": [[1, "submodules"], [6, "submodules"], [9, "submodules"]], "airflow.providers.celery.executors.celery_executor": [[2, "module-airflow.providers.celery.executors.celery_executor"]], "Classes": [[2, "classes"], [3, "classes"], [4, "classes"], [8, "classes"]], "airflow.providers.celery.executors.celery_executor_utils": [[3, "module-airflow.providers.celery.executors.celery_executor_utils"]], "airflow.providers.celery.executors.celery_kubernetes_executor": [[4, "module-airflow.providers.celery.executors.celery_kubernetes_executor"]], "airflow.providers.celery.executors.default_celery": [[5, "module-airflow.providers.celery.executors.default_celery"]], "airflow.providers.celery.executors": [[6, "module-airflow.providers.celery.executors"]], "Package Contents": [[6, "package-contents"], [7, "package-contents"]], "airflow.providers.celery": [[7, "module-airflow.providers.celery"]], "Subpackages": [[7, "subpackages"]], "airflow.providers.celery.sensors.celery_queue": [[8, "module-airflow.providers.celery.sensors.celery_queue"]], "airflow.providers.celery.sensors": [[9, "module-airflow.providers.celery.sensors"]], "Celery Executor": [[10, "celery-executor"]], "Architecture": [[10, "architecture"]], "Task execution process": [[10, "task-execution-process"]], "Queues": [[10, "queues"]], "CeleryKubernetes Executor": [[11, "celerykubernetes-executor"]], "When to use CeleryKubernetesExecutor": [[11, "when-to-use-celerykubernetesexecutor"]], "Changelog": [[12, "changelog"]], "3.6.2": [[12, "id1"], [14, "id1"]], "Bug Fixes": [[12, "bug-fixes"], [12, "id3"], [12, "id8"], [12, "id10"], [12, "id14"], [12, "id19"], [12, "id22"], [12, "id44"]], "Misc": [[12, "misc"], [12, "id4"], [12, "id6"], [12, "id12"], [12, "id17"], [12, "id20"], [12, "id23"], [12, "id25"], [12, "id27"], [12, "id30"], [12, "id32"], [12, "id35"], [12, "id38"], [12, "id42"], [12, "id46"], [12, "id48"]], "3.6.1": [[12, "id2"], [14, "id2"]], "3.6.0": [[12, "id5"], [14, "id3"]], "Features": [[12, "features"], [12, "id29"], [12, "id50"]], "3.5.2": [[12, "id7"], [14, "id4"]], "3.5.1": [[12, "id9"], [14, "id5"]], "3.5.0": [[12, "id11"], [14, "id6"]], "3.4.1": [[12, "id13"], [14, "id7"]], "3.4.0": [[12, "id15"], [14, "id8"]], "3.3.4": [[12, "id18"], [14, "id9"]], "3.3.3": [[12, "id21"], [14, "id10"]], "3.3.2": [[12, "id24"], [14, "id11"]], "3.3.1": [[12, "id26"], [14, "id12"]], "3.3.0": [[12, "id28"], [14, "id13"]], "3.2.1": [[12, "id31"], [14, "id14"]], "3.2.0": [[12, "id33"], [14, "id15"]], "3.1.0": [[12, "id36"], [14, "id16"]], "3.0.0": [[12, "id39"], [14, "id17"]], "Breaking changes": [[12, "breaking-changes"], [12, "id52"]], "2.1.4": [[12, "id41"], [14, "id18"]], "2.1.3": [[12, "id43"], [14, "id19"]], "2.1.2": [[12, "id45"], [14, "id20"]], "2.1.1": [[12, "id47"], [14, "id21"]], "2.1.0": [[12, "id49"], [14, "id22"]], "2.0.0": [[12, "id51"], [14, "id23"]], "1.0.1": [[12, "id53"], [14, "id24"]], "1.0.0": [[12, "id54"], [14, "id25"]], "Celery Executor Commands": [[13, "celery-executor-commands"]], "Positional Arguments": [[13, "positional-arguments"], [13, "positional-arguments_repeat1"]], "Sub-commands": [[13, "Sub-commands"], [13, "Sub-commands_repeat1"]], "celery": [[13, "celery"]], "flower": [[13, "flower"]], "Named Arguments": [[13, "named-arguments"], [13, "named-arguments_repeat1"], [13, "named-arguments_repeat2"]], "stop": [[13, "stop"]], "worker": [[13, "worker"]], "Package apache-airflow-providers-celery": [[14, "package-apache-airflow-providers-celery"]], "Configuration Reference": [[15, "configuration-reference"]], "Sections:": [[15, "sections"]], "[celery]": [[15, "celery"]], "broker_url": [[15, "broker-url"]], "celery_app_name": [[15, "celery-app-name"]], "celery_config_options": [[15, "celery-config-options"]], "flower_basic_auth": [[15, "flower-basic-auth"]], "flower_host": [[15, "flower-host"]], "flower_port": [[15, "flower-port"]], "flower_url_prefix": [[15, "flower-url-prefix"]], "operation_timeout": [[15, "operation-timeout"]], "pool": [[15, "pool"]], "result_backend": [[15, "result-backend"]], "result_backend_sqlalchemy_engine_options": [[15, "result-backend-sqlalchemy-engine-options"]], "ssl_active": [[15, "ssl-active"]], "ssl_cacert": [[15, "ssl-cacert"]], "ssl_cert": [[15, "ssl-cert"]], "ssl_key": [[15, "ssl-key"]], "sync_parallelism": [[15, "sync-parallelism"]], "task_acks_late": [[15, "task-acks-late"]], "task_publish_max_retries": [[15, "task-publish-max-retries"]], "task_track_started": [[15, "task-track-started"]], "worker_autoscale": [[15, "worker-autoscale"]], "worker_concurrency": [[15, "worker-concurrency"]], "worker_enable_remote_control": [[15, "worker-enable-remote-control"]], "worker_precheck": [[15, "worker-precheck"]], "worker_prefetch_multiplier": [[15, "worker-prefetch-multiplier"]], "default_queue (Deprecated)": [[15, "default-queue-deprecated"]], "stalled_task_timeout (Deprecated)": [[15, "stalled-task-timeout-deprecated"]], "task_adoption_timeout (Deprecated)": [[15, "task-adoption-timeout-deprecated"]], "worker_log_server_port (Deprecated)": [[15, "worker-log-server-port-deprecated"]], "[celery_broker_transport_options]": [[15, "celery-broker-transport-options"]], "sentinel_kwargs": [[15, "sentinel-kwargs"]], "visibility_timeout": [[15, "visibility-timeout"]], "[celery_kubernetes_executor]": [[15, "celery-kubernetes-executor"]], "kubernetes_queue": [[15, "kubernetes-queue"]], "apache-airflow-providers-celery": [[16, "apache-airflow-providers-celery"]], "apache-airflow-providers-celery package": [[16, "apache-airflow-providers-celery-package"]], "Provider package": [[16, "provider-package"]], "Installation": [[16, "installation"]], "Requirements": [[16, "requirements"]], "Cross provider package dependencies": [[16, "cross-provider-package-dependencies"]], "Downloading official packages": [[16, "downloading-official-packages"]], "Installing from sources": [[17, "installing-from-sources"]], "Released packages": [[17, "released-packages"]], "Release integrity": [[17, "release-integrity"]], "Verifying PyPI releases": [[17, "verifying-pypi-releases"]], "Releasing security patches": [[18, "releasing-security-patches"]]}, "indexentries": {"worker_process_name (in module airflow.providers.celery.cli.celery_command)": [[0, "airflow.providers.celery.cli.celery_command.WORKER_PROCESS_NAME"]], "airflow.providers.celery.cli.celery_command": [[0, "module-airflow.providers.celery.cli.celery_command"]], "flower() (in module airflow.providers.celery.cli.celery_command)": [[0, "airflow.providers.celery.cli.celery_command.flower"]], "logger_setup_handler() (in module airflow.providers.celery.cli.celery_command)": [[0, "airflow.providers.celery.cli.celery_command.logger_setup_handler"]], "module": [[0, "module-airflow.providers.celery.cli.celery_command"], [1, "module-airflow.providers.celery.cli"], [2, "module-airflow.providers.celery.executors.celery_executor"], [3, "module-airflow.providers.celery.executors.celery_executor_utils"], [4, "module-airflow.providers.celery.executors.celery_kubernetes_executor"], [5, "module-airflow.providers.celery.executors.default_celery"], [6, "module-airflow.providers.celery.executors"], [7, "module-airflow.providers.celery"], [8, "module-airflow.providers.celery.sensors.celery_queue"], [9, "module-airflow.providers.celery.sensors"]], "stop_worker() (in module airflow.providers.celery.cli.celery_command)": [[0, "airflow.providers.celery.cli.celery_command.stop_worker"]], "worker() (in module airflow.providers.celery.cli.celery_command)": [[0, "airflow.providers.celery.cli.celery_command.worker"]], "airflow.providers.celery.cli": [[1, "module-airflow.providers.celery.cli"]], "airflow_version (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.AIRFLOW_VERSION"]], "arg_autoscale (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_AUTOSCALE"]], "arg_broker_api (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_BROKER_API"]], "arg_celery_hostname (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_CELERY_HOSTNAME"]], "arg_concurrency (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_CONCURRENCY"]], "arg_flower_basic_auth (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_BASIC_AUTH"]], "arg_flower_conf (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_CONF"]], "arg_flower_hostname (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_HOSTNAME"]], "arg_flower_port (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_PORT"]], "arg_flower_url_prefix (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_FLOWER_URL_PREFIX"]], "arg_queues (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_QUEUES"]], "arg_umask (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_UMASK"]], "arg_without_gossip (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_WITHOUT_GOSSIP"]], "arg_without_mingle (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.ARG_WITHOUT_MINGLE"]], "celery_cli_command_path (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.CELERY_CLI_COMMAND_PATH"]], "celery_commands (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.CELERY_COMMANDS"]], "celery_send_err_msg_header (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.CELERY_SEND_ERR_MSG_HEADER"]], "celeryexecutor (class in airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor"]], "taskinstanceincelery (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.TaskInstanceInCelery"]], "__getattr__() (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.__getattr__"]], "airflow.providers.celery.executors.celery_executor": [[2, "module-airflow.providers.celery.executors.celery_executor"]], "base_version (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.base_version"]], "change_state() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.change_state"]], "cleanup_stuck_queued_tasks() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.cleanup_stuck_queued_tasks"]], "debug_dump() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.debug_dump"]], "end() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.end"]], "get_cli_commands() (airflow.providers.celery.executors.celery_executor.celeryexecutor static method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.get_cli_commands"]], "log (in module airflow.providers.celery.executors.celery_executor)": [[2, "airflow.providers.celery.executors.celery_executor.log"]], "start() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.start"]], "supports_ad_hoc_ti_run (airflow.providers.celery.executors.celery_executor.celeryexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.supports_ad_hoc_ti_run"]], "supports_sentry (airflow.providers.celery.executors.celery_executor.celeryexecutor attribute)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.supports_sentry"]], "sync() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.sync"]], "terminate() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.terminate"]], "try_adopt_task_instances() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.try_adopt_task_instances"]], "update_all_task_states() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.update_all_task_states"]], "update_task_state() (airflow.providers.celery.executors.celery_executor.celeryexecutor method)": [[2, "airflow.providers.celery.executors.celery_executor.CeleryExecutor.update_task_state"]], "bulkstatefetcher (class in airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.BulkStateFetcher"]], "celery_fetch_err_msg_header (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.CELERY_FETCH_ERR_MSG_HEADER"]], "exceptionwithtraceback (class in airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.ExceptionWithTraceback"]], "operation_timeout (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.OPERATION_TIMEOUT"]], "taskinstanceincelery (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.TaskInstanceInCelery"]], "airflow.providers.celery.executors.celery_executor_utils": [[3, "module-airflow.providers.celery.executors.celery_executor_utils"]], "app (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.app"]], "celery_configuration (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.celery_configuration"]], "execute_command() (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.execute_command"]], "fetch_celery_task_state() (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.fetch_celery_task_state"]], "get_many() (airflow.providers.celery.executors.celery_executor_utils.bulkstatefetcher method)": [[3, "airflow.providers.celery.executors.celery_executor_utils.BulkStateFetcher.get_many"]], "log (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.log"]], "on_celery_import_modules() (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.on_celery_import_modules"]], "send_task_to_executor() (in module airflow.providers.celery.executors.celery_executor_utils)": [[3, "airflow.providers.celery.executors.celery_executor_utils.send_task_to_executor"]], "celerykubernetesexecutor (class in airflow.providers.celery.executors.celery_kubernetes_executor)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor"]], "airflow.providers.celery.executors.celery_kubernetes_executor": [[4, "module-airflow.providers.celery.executors.celery_kubernetes_executor"]], "callback_sink (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.callback_sink"]], "change_sensor_mode_to_reschedule (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "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)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.cleanup_stuck_queued_tasks"]], "debug_dump() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.debug_dump"]], "end() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.end"]], "get_cli_commands() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor static method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.get_cli_commands"]], "get_event_buffer() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.get_event_buffer"]], "get_task_log() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.get_task_log"]], "has_task() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.has_task"]], "heartbeat() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.heartbeat"]], "is_local (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.is_local"]], "is_production (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.is_production"]], "is_single_threaded (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.is_single_threaded"]], "job_id (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor property)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.job_id"]], "kubernetes_queue() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.kubernetes_queue"]], "queue_command() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.queue_command"]], "queue_task_instance() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.queue_task_instance"]], "queued_tasks (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor property)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.queued_tasks"]], "running (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor property)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.running"]], "send_callback() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.send_callback"]], "serve_logs (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.serve_logs"]], "slots_available (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor property)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.slots_available"]], "start() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.start"]], "supports_ad_hoc_ti_run (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.supports_ad_hoc_ti_run"]], "supports_pickling (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.supports_pickling"]], "supports_sentry (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor attribute)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.supports_sentry"]], "terminate() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.terminate"]], "try_adopt_task_instances() (airflow.providers.celery.executors.celery_kubernetes_executor.celerykubernetesexecutor method)": [[4, "airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor.try_adopt_task_instances"]], "default_celery_config (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.DEFAULT_CELERY_CONFIG"]], "airflow.providers.celery.executors.default_celery": [[5, "module-airflow.providers.celery.executors.default_celery"]], "broker_transport_options (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.broker_transport_options"]], "broker_url (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.broker_url"]], "broker_use_ssl (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.broker_use_ssl"]], "celery_ssl_active (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.celery_ssl_active"]], "log (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.log"]], "match_not_recommended_backend (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.match_not_recommended_backend"]], "result_backend (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.result_backend"]], "sentinel_kwargs (in module airflow.providers.celery.executors.default_celery)": [[5, "airflow.providers.celery.executors.default_celery.sentinel_kwargs"]], "airflow.providers.celery.executors": [[6, "module-airflow.providers.celery.executors"]], "base_version (in module airflow.providers.celery.executors)": [[6, "airflow.providers.celery.executors.base_version"]], "__version__ (in module airflow.providers.celery)": [[7, "airflow.providers.celery.__version__"]], "airflow.providers.celery": [[7, "module-airflow.providers.celery"]], "celeryqueuesensor (class in airflow.providers.celery.sensors.celery_queue)": [[8, "airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor"]], "airflow.providers.celery.sensors.celery_queue": [[8, "module-airflow.providers.celery.sensors.celery_queue"]], "poke() (airflow.providers.celery.sensors.celery_queue.celeryqueuesensor method)": [[8, "airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor.poke"]], "airflow.providers.celery.sensors": [[9, "module-airflow.providers.celery.sensors"]], "pythonpath": [[10, "index-0"]], "environment variable": [[10, "index-0"]]}}) |