airflow legacy_commands 源码
airflow legacy_commands 代码
文件路径：/airflow/cli/commands/legacy_commands.py
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
from __future__ import annotations
from argparse import ArgumentError
COMMAND_MAP = {
"worker": "celery worker",
"flower": "celery flower",
"trigger_dag": "dags trigger",
"delete_dag": "dags delete",
"show_dag": "dags show",
"list_dag": "dags list",
"dag_status": "dags status",
"backfill": "dags backfill",
"list_dag_runs": "dags list-runs",
"pause": "dags pause",
"unpause": "dags unpause",
"test": "tasks test",
"clear": "tasks clear",
"list_tasks": "tasks list",
"task_failed_deps": "tasks failed-deps",
"task_state": "tasks state",
"run": "tasks run",
"render": "tasks render",
"initdb": "db init",
"resetdb": "db reset",
"upgradedb": "db upgrade",
"checkdb": "db check",
"shell": "db shell",
"pool": "pools",
"list_users": "users list",
"create_user": "users create",
"delete_user": "users delete",
}
def check_legacy_command(action, value):
"""Checks command value and raise error if value is in removed command"""
new_command = COMMAND_MAP.get(value)
if new_command is not None:
msg = f"`airflow {value}` command, has been removed, please use `airflow {new_command}`"
raise ArgumentError(action, msg)
相关信息
相关文章
airflow cheat_sheet_command 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
8、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦