Airflow kubernetes executor logs8/18/2023 # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY # software distributed under the License is distributed on an # Unless required by applicable law or agreed to in writing, # "License") you may not use this file except in compliance # to you under the Apache License, Version 2.0 (the # distributed with this work for additional information # or more contributor license agreements. # Licensed to the Apache Software Foundation (ASF) under one ALL_NAMESPACES Constant POD_EXECUTOR_DONE_KEY Constant ResourceVersion Class _new_ Function KubernetesJobWatcher Class _init_ Function run Function _pod_events Function _run Function process_error Function process_status Function AirflowKubernetesScheduler Class _init_ Function run_pod_async Function _make_kube_watcher Function _make_kube_watchers Function _health_check_kube_watchers Function run_next Function delete_pod Function patch_pod_executor_done Function sync Function process_watcher_task Function _flush_watcher_queue Function terminate Function get_base_pod_from_template Function KubernetesExecutor Class _init_ Function _list_pods Function clear_not_launched_queued_tasks Function start Function execute_async Function sync Function _change_state Function _get_pod_namespace Function get_task_log Function try_adopt_task_instances Function cleanup_stuck_queued_tasks Function adopt_launched_task Function _adopt_completed_pods Function _flush_task_queue Function _flush_result_queue Function end Function terminate Function
0 Comments
Leave a Reply.AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |