• Home
• Index

Index

_

__getattr__() (in module airflow.providers.celery.executors.celery_executor)

__version__ (in module airflow.providers.celery)

A

airflow.providers.celery module airflow.providers.celery.cli module airflow.providers.celery.cli.celery_command module airflow.providers.celery.executors module airflow.providers.celery.executors.celery_executor module airflow.providers.celery.executors.celery_executor_utils module airflow.providers.celery.executors.celery_kubernetes_executor module airflow.providers.celery.executors.default_celery module airflow.providers.celery.sensors module

airflow.providers.celery.sensors.celery_queue module app (in module airflow.providers.celery.executors.celery_executor_utils) ARG_AUTOSCALE (in module airflow.providers.celery.executors.celery_executor) ARG_BROKER_API (in module airflow.providers.celery.executors.celery_executor) ARG_CELERY_HOSTNAME (in module airflow.providers.celery.executors.celery_executor) ARG_CONCURRENCY (in module airflow.providers.celery.executors.celery_executor) ARG_FLOWER_BASIC_AUTH (in module airflow.providers.celery.executors.celery_executor) ARG_FLOWER_CONF (in module airflow.providers.celery.executors.celery_executor) ARG_FLOWER_HOSTNAME (in module airflow.providers.celery.executors.celery_executor) ARG_FLOWER_PORT (in module airflow.providers.celery.executors.celery_executor) ARG_FLOWER_URL_PREFIX (in module airflow.providers.celery.executors.celery_executor) ARG_QUEUES (in module airflow.providers.celery.executors.celery_executor) ARG_UMASK (in module airflow.providers.celery.executors.celery_executor) ARG_WITHOUT_GOSSIP (in module airflow.providers.celery.executors.celery_executor) ARG_WITHOUT_MINGLE (in module airflow.providers.celery.executors.celery_executor)

B

base_version (in module airflow.providers.celery.executors) broker_transport_options (in module airflow.providers.celery.executors.default_celery)

broker_url (in module airflow.providers.celery.executors.default_celery) broker_use_ssl (in module airflow.providers.celery.executors.default_celery) BulkStateFetcher (class in airflow.providers.celery.executors.celery_executor_utils)

C

callback_sink (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) CELERY_CLI_COMMAND_PATH (in module airflow.providers.celery.executors.celery_executor) CELERY_COMMANDS (in module airflow.providers.celery.executors.celery_executor) celery_configuration (in module airflow.providers.celery.executors.celery_executor_utils) CELERY_FETCH_ERR_MSG_HEADER (in module airflow.providers.celery.executors.celery_executor_utils) CELERY_SEND_ERR_MSG_HEADER (in module airflow.providers.celery.executors.celery_executor) celery_ssl_active (in module airflow.providers.celery.executors.default_celery)

CeleryExecutor (class in airflow.providers.celery.executors.celery_executor) CeleryKubernetesExecutor (class in airflow.providers.celery.executors.celery_kubernetes_executor) CeleryQueueSensor (class in airflow.providers.celery.sensors.celery_queue) change_sensor_mode_to_reschedule (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) change_state() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method) cleanup_stuck_queued_tasks() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

D

debug_dump() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

DEFAULT_CELERY_CONFIG (in module airflow.providers.celery.executors.default_celery)

E

end() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) environment variable PYTHONPATH

ExceptionWithTraceback (class in airflow.providers.celery.executors.celery_executor_utils) execute_command() (in module airflow.providers.celery.executors.celery_executor_utils)

F

fetch_celery_task_state() (in module airflow.providers.celery.executors.celery_executor_utils)

flower() (in module airflow.providers.celery.cli.celery_command)

G

get_cli_commands() (airflow.providers.celery.executors.celery_executor.CeleryExecutor static method) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor static method)

get_event_buffer() (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) get_many() (airflow.providers.celery.executors.celery_executor_utils.BulkStateFetcher method) get_task_log() (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

H

has_task() (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

heartbeat() (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

I

is_local (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute)

is_production (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) is_single_threaded (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute)

J

job_id (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property)

K

kubernetes_queue() (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

L

log (in module airflow.providers.celery.executors.celery_executor) (in module airflow.providers.celery.executors.celery_executor_utils) (in module airflow.providers.celery.executors.default_celery)

logger_setup_handler() (in module airflow.providers.celery.cli.celery_command)

M

match_not_recommended_backend (in module airflow.providers.celery.executors.default_celery) module airflow.providers.celery airflow.providers.celery.cli airflow.providers.celery.cli.celery_command airflow.providers.celery.executors airflow.providers.celery.executors.celery_executor airflow.providers.celery.executors.celery_executor_utils airflow.providers.celery.executors.celery_kubernetes_executor airflow.providers.celery.executors.default_celery airflow.providers.celery.sensors airflow.providers.celery.sensors.celery_queue

O

on_celery_import_modules() (in module airflow.providers.celery.executors.celery_executor_utils)

OPERATION_TIMEOUT (in module airflow.providers.celery.executors.celery_executor_utils)

P

poke() (airflow.providers.celery.sensors.celery_queue.CeleryQueueSensor method)

PYTHONPATH

Q

queue_command() (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

queue_task_instance() (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) queued_tasks (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property)

R

result_backend (in module airflow.providers.celery.executors.default_celery)

running (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property)

S

send_callback() (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) send_task_to_executor() (in module airflow.providers.celery.executors.celery_executor_utils) sentinel_kwargs (in module airflow.providers.celery.executors.default_celery) serve_logs (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) slots_available (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property) slots_occupied (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property) start() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

stop_worker() (in module airflow.providers.celery.cli.celery_command) supports_ad_hoc_ti_run (airflow.providers.celery.executors.celery_executor.CeleryExecutor attribute) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) supports_pickling (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) supports_sentry (airflow.providers.celery.executors.celery_executor.CeleryExecutor attribute) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) sync() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method)

T

TaskInstanceInCelery (in module airflow.providers.celery.executors.celery_executor) (in module airflow.providers.celery.executors.celery_executor_utils) terminate() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

try_adopt_task_instances() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method) (airflow.providers.celery.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method)

U

update_all_task_states() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method)

update_task_state() (airflow.providers.celery.executors.celery_executor.CeleryExecutor method)

W

worker() (in module airflow.providers.celery.cli.celery_command)

WORKER_PROCESS_NAME (in module airflow.providers.celery.cli.celery_command)

PreviousNext

Was this entry helpful?