如何删除Airflow中的默认DAG？
Airflow是一个开源的任务调度和工作流管理平台，它使用DAG（有向无环图）来定义工作流。默认情况下，Airflow会提供一些示例DAG，如果你想删除其中的默认DAG，可以按照以下步骤进行操作：
- 进入Airflow的安装目录，通常是
/usr/local/airflow或~/airflow。 - 导航到
dags目录，其中包含所有的DAG文件。 - 查找并删除你想要删除的默认DAG文件。默认DAG文件通常以
example_开头，例如example_bash_operator.py。 - 重新启动Airflow的Web服务器和调度器，以使更改生效。
删除默认DAG后，你可以根据自己的需求创建和管理自定义的DAG。如果你需要了解更多关于Airflow的信息，可以参考腾讯云的产品介绍页面：Airflow产品介绍。
请注意，以上答案仅供参考，具体操作步骤可能因Airflow版本和部署环境而有所不同。建议在进行任何更改之前，先备份相关文件以防止意外情况发生。
相关·内容
我刚刚在Python3和Composer image版本composer-1.4.0-airflow-1.10.0上设置了一个Cloud Composer Environment。否则，所有设置都是“常用的”；即没有配置覆盖。
我正在尝试测试一个非常简单的DAG。它在我的本地Airflow服务器上运行没有问题，但在Cloud Composer上，web服务器的任务信息视图显示消息Dependencies Blocking Task From Getting Scheduled
依赖关系是Unknown，原因如下：
All dependencies are met but the task in
浏览 19提问于2018-12-20得票数 3
其目的是通过rest api调用从UI中删除airflow dag。我尝试了调用.../delete?dag_id=<dag_id>，这个rest调用失败了，报告缺少CSRF令牌。如何从airflow服务器获取CSRF令牌？或者有没有更好的方法从airflow UI中自动删除dag？(不是从airflow UI手动按下删除按钮)
浏览 3提问于2020-06-11得票数 0
1回答
我按照中的说明动态创建DAGs，通过变量k修改要创建的dags的数量
from datetime import datetime
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
def create_dag(dag_id,
schedule,
dag_number,
default_args):
def hello_world_py(*args):
prin
浏览 16提问于2021-02-20得票数 2
我的launch.json为给定的调试会话指定了一个参数列表(在本例中用于气流调试)：
{
"version": "0.2.0",
"configurations": [
{
"name": "airflow_debug",
"type": "python",
"request": "launch",
"program
浏览 11提问于2022-11-25得票数 0
回答已采纳
当尝试通过airflow trigger_dag test_dag运行dag时，我得到了错误：airflow.exceptions.DagNotFound: Dag id test_task not found in DagModel。
运行airflow list_dags时，DAG正确列出。我还进行了检查，以确保将$AIRFLOW_HOME目录正确设置为dag所在的位置。我能让它工作的唯一方法就是运行一个特定的任务，比如airflow test test_dag test_task。运行python dags/test_dag.py时未显示任何错误。
导入后，dag文件本身中的代码：
de
浏览 8提问于2019-09-12得票数 3
我从airflow dag_bag和相应的.pyc文件中删除了dag。当我尝试从airflow UI中删除相同的dag时，它显示此错误: Dag id MY_DAG_ID仍然在DagBag中。首先删除DAG文件。我使用的airflow版本是1.10.4，即使在重新启动airflow之后，我也无法从UI中删除。我之前使用的是1.10.3，但我从未遇到过这个问题。在从dags文件夹中删除后，我可以从UI中删除。
当我点击UI中的dag时，它显示: DAG "MY_DAG_ID“似乎丢失了。(这是我从文件夹中删除dag时所预期的)
浏览 2提问于2019-12-03得票数 1
13回答
我已经启动了Airflow网络服务器并安排了一些dags。我可以在web GUI上看到dags。
如何删除正在运行并在web GUI中显示的特定DAG？是否有Airflow CLI命令来执行此操作？
我环顾四周，但找不到一个简单的方法来删除一个DAG，一旦它已经加载和调度。
浏览 360提问于2016-11-17得票数 83
回答已采纳
刚从气流开始，想用BashOperator运行简单的dag，输出'Hello‘来安慰我，我注意到我的状态无限期地停留在’运行‘中。
当我讨论任务细节时，我得到了以下信息：
任务处于“无”状态，这不是执行的有效状态。必须清除该任务才能运行.
任何建议或暗示都是非常感谢的。
达格：
from datetime import timedelta
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.utils.dates import days_ago
de
浏览 3提问于2020-11-05得票数 1
回答已采纳
当我尝试运行这个任务时，我得到了以下错误：
from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator
from airflow import DAG
from datetime import datetime, timedelta
default_args = {
"owner": "airflow",
"depends_on_past": False,
"start_date": dateti
浏览 1提问于2019-11-26得票数 0
如何获取在具有dag-id的airflow dag中运行的任务列表？任务之间的连接并不重要。谢谢
假设我有来自"airflow list_dags“的dag-id
浏览 94提问于2019-07-30得票数 2
我正在使用Airflow Version 2.2.5/Composer 2.0.15实现任务超时错误。在Airflow version2.2.3 /Composer Version 1.18.0中，相同的代码运行得非常好。
错误信息：
Broken DAG: [/home/airflow/gcs/dags/test_dag.py] Traceback (most recent call last):
File "/opt/python3.8/lib/python3.8/enum.py", line 256, in __new__
if canonical_membe
浏览 32提问于2022-06-13得票数 0
回答已采纳
我想将DAG文件添加到Airflow中，它在Ubuntu上的Docker中运行。我使用了以下，其中包含配置和到docker镜像的链接。当我运行docker run -d -p 8080:8080 puckel/docker-airflow webserver时，一切都正常工作。但我找不到一种方法来安全地将DAG添加到气流中。或者，我运行了docker run -d -p 8080:8080 puckel/docker-airflow webserver -v /root/dags:/usr/local/airflow/dags，也没有成功。
我尝试编辑/config/airflow.cfg并将
浏览 3提问于2018-09-17得票数 10
1回答
我是在气流中的新人，但我不知道如何正确地发布新的python脚本或jars到气流服务器。问题的部分是/home/airflow/airflow/dags/scripts/file1.py.如果我创建了一个新版本的file1.py，我想在气流服务器上传播这个新版本。简单的解决方案可以是通过FTP
我找到了，这可能是我在应用程序中的第一步，并获得了我想要的脚本版本。
( 1)在Aiflow，是否有比单独一步更好的方法？
2)问题的第二部分是如何处理jar文件。我的解决方案是在某个地方发布jar文件(例如，Nexus存储库)，并在气流中有一个单独的步骤来下载我的文件的最新版本。
from airfl
浏览 2提问于2020-03-03得票数 0
1回答
我想暂停空闲和冗余的DAG，我如何知道哪些DAG未暂停，哪些DAG已暂停？
因此，我有一个要使用执行airflow pause <dag_id>的have命令取消暂停的DAG的列表。我想通过检查每个DAG的pause状态来了解命令是否成功。我已经检查了airflow webserver，似乎所有暂停的DAG仍在运行。
def pause_idle_dags(dags = ["myTutorial"]):
"""
Pauses dags from the airflow
:param dags: dags conside
浏览 0提问于2018-12-27得票数 4
1回答
我无法在气流中部署DAG。经常犯同样的错误。运行在8080端口和调度器上。
Running %s on host %s <TaskInstance: bworkflow_dag.bworkflow_template 2020-08-11T00:00:00+00:00 [failed]> airflow-instance-test.c.cc-data-sandbox.internal
[2020-08-11 14:46:29,030] {__init__.py:50} INFO - Using executor SequentialExecutor
[2020-08-11 14:46
浏览 3提问于2020-08-11得票数 3
回答已采纳
我已经创建了一个DAG，它计划在每5分钟内使用cron语法执行。另外，这个池是为这个进程创建的，只有一个槽。
我尝试重新启动服务器/调度程序并重置数据库。目前，DAG正在UTC时间运行。此外，我还试图设置我的本地时区，即“欧洲/明斯克”(UTC+3)，但它没有产生任何效果。
import random
import time
import airflow
from airflow.models import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_ope
浏览 2提问于2019-06-14得票数 3
回答已采纳
我正在尝试使用EmailOperator在我的气流DAG。我已经设置了SES和SNMP配置，但由于下面的错误，我甚至无法验证配置是否正常。
电子邮件配置：
[email]
email_backend = airflow.providers.amazon.aws.utils.emailer.send_email
email_conn_id = {{ AIRFLOW_CONN_AWS_DEFAULT}}
smtp_host = email-smtp.{{ AWS_DEFAULT_REGION }}.amazonaws.com
smtp_starttls = True
smtp_ssl = Fals
浏览 4提问于2022-03-13得票数 1
1回答
写入气流2台
、、
我已经在气流1.10.14很长一段时间了，现在我正在尝试升级到气流2.4.3 (最新？)我已经在新的格式中构建了这个数据库，希望能吸收语言，了解新格式的工作原理。下面是我的爸爸：
from airflow.decorators import dag, task
from airflow.models import Variable
from airflow.providers.google.cloud.operators.bigquery import BigQueryInsertJobOperator
from airflow.providers.microsoft.mssql.opera
浏览 9提问于2022-11-17得票数 1
回答已采纳
我试图从云存储桶中选择一个JSON文件，并使用Airflow将其转储到BigQuery中，但是，我得到了以下错误：
Access Denied: BigQuery BigQuery: Missing required OAuth scope. Need BigQuery or Cloud Platform write scope。
这是我的密码：
from datetime import timedelta, datetime
import json
from airflow.operators.bash_operator import BashOperator
from airflow.co
浏览 5提问于2022-11-03得票数 0
1回答
我一直在尝试创建一个新的dag文件，但是像airflow dags list或airflow webserver --port 8080这样的东西无法检测到该文件。
我已经从一个example_python_operator.py中创建了我的守护文件，我已经为此创建了一个新的管理用户。它放在~/airflow中。执行export AIRFLOW_HOME=~/airflow命令。
我的守护文件
import logging
import shutil
import time
from datetime import datetime
from pprint import pprint
fro
浏览 5提问于2022-10-14得票数 0
1回答
我对气流很陌生，但我设法在本地运行它(用SQLite)跟踪文档。
考虑到我需要一些额外的工具，我试着把所有的东西都放入一个码头，但我没有做到。
我删除了添加的所有内容，但仍然找不到问题。然后，我遵循了这个，将文件的版本从3.8降到3.3，并删除了重新启动策略；但我甚至达不到端口8080。
更进一步，我找到了这个，它允许我到达端口8080，但是当我尝试使用命令行创建一个用户时，它会从数据库中返回一个错误，告诉我不存在名为log或dags的表。通过UI创建用户可以正常工作，但我觉得奇怪的是，db没有看到这一点(我检查了db容器日志)。
一个小的例子是下面的docker-compose.yml
ve
浏览 14提问于2021-02-08得票数 1
5回答
我正在尝试使用airflow来定义我想要从命令行手动触发的特定工作流。
我创建了DAG并添加了一系列任务。
dag = airflow.DAG(
"DAG_NAME",
start_date=datetime(2015, 1, 1),
schedule_interval=None,
default_args=args)
然后我在终端中运行
airflow trigger_dag DAG_NAME
什么都不会发生。调度程序正在另一个线程中运行。任何方向都是非常受欢迎的。谢谢
浏览 2提问于2016-05-05得票数 24
我在dags目录中有两个文件- dag_1.py和dag_2.py
dag_1.py创建静态DAG，dag_2.py根据外部json文件在某个位置创建动态DAG。
静态DAG (由dag_1.py创建)包含一个稍后阶段的任务，该任务为dag_2.py和动态DAG生成一些这些输入json文件。
过去，在不使用DAG序列化的情况下，气流1.x版本可以很好地工作。但随着气流2.0DAG系列化已成为强制性的。有时，当生成动态DAG时，我会在Scheduler中得到以下异常-
[2021-01-02 06:17:39,493] {scheduler_job.py:1293} ERROR - Except
浏览 11提问于2021-01-05得票数 4
回答已采纳
version: "3.7"
services:
postgres:
image: "postgres:13"
container_name: "postgres"
environment:
- POSTGRES_USER=airflow
- POSTGRES_PASSWORD=airflow
- POSTGRES_DB=airflow
ports:
- "5431:5431"
浏览 13提问于2022-08-12得票数 0
回答已采纳
3回答
Apache气流不调度任务
、、、、
我已经安装了airflow(V1.9.0版本)和python2.7。为了测试它的安装是否正确，我尝试从浏览器中的交互式视图触发一个教程DAG。接口显示DAG正在运行，但调度程序没有显示任何活动。
下面是我尝试过的步骤
安装气流
pip install apache-airflow
安装密码用于设置使用fernet密钥的加密
pip install apache-airflow[crypto]
生成一个fernet_key并添加airflow.cfg文件：
from cryptography.fernet import Fernet
fernet_key= F
浏览 0提问于2018-02-02得票数 6
在airflow.cfg中设置catchup_by_default=False似乎不起作用。此外，将catchup=False添加到DAG也不起作用。
以下是如何重现该问题的方法。我总是从头开始运行airflow resetdb。一旦我取消暂停dag，任务就开始回填。
这是dag的设置。我只是在用。
default_args = {
"owner": "airflow",
"depends_on_past": False,
"start_date": datetime(2018, 9, 16),
&
浏览 1提问于2018-09-05得票数 4
在虚拟环境中设置Airflow (2.1.4)，然后安装第三方插件"pip install simple-dag-editor“
插件已成功安装，但是检查插件列表时，发现有重复的条目。
(venv) root@test-server:/opt/airflow$ airflow plugins
name | source | flask_blueprints | appbuilder_v
浏览 2提问于2021-09-29得票数 0
1回答
我有一个在MySQL表中插入一些记录的dag，我想每隔2小时运行我的dag。为此，我有以下代码：
from datetime import timedelta, datetime
import pymysql
import airflow
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.operators import MySqlOperator
default_args = {
'owner': 'airflow
浏览 54提问于2021-06-04得票数 0
回答已采纳
我正在使用apache airflow和BashOperator。每个BashOperator执行一个python脚本。例如：
from airflow.models import DAG
from airflow.operators.bash_operator import BashOperator
with DAG(dag_id='dag_example', default_args=None,
schedule_interval='0 2 */2 * *',
catchup=False) as dag:
浏览 18提问于2020-05-20得票数 1
我试图使用码头操作员自动执行一些脚本使用气流。
气流版本：apache-airflow==1.10.12
我想要做的是“复制”我的项目的所有文件(文件夹和文件)到容器使用这段代码。
以下文件ml-intermediate.py位于此目录~/airflow/dags/ml-intermediate.py中
"""
Template to convert a Ploomber DAG to Airflow
"""
from airflow import DAG
from airflow.operators.bash_operator import B
浏览 2提问于2020-11-21得票数 0
我在更新dag文件时遇到问题。Dag仍然保留着我的dag文件的旧版本。我添加了一个任务，但当我检查日志和UI (DAG->Code)时，它似乎没有更新。
我有非常简单的任务。我当然检查了airflow.cfg中的dag目录路径，并重新启动了airflow webserver/scheduler。我运行它没有问题(但使用旧的dag文件)。
浏览 23提问于2017-07-13得票数 5
1回答
这是我在dags文件夹中的数据文件。
Code that goes along with the Airflow located at:
http://airflow.readthedocs.org/en/latest/tutorial.html
"""
from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator
from datetime im
浏览 0提问于2020-06-11得票数 0
回答已采纳
我使用的是one_success触发器规则，这样如果父任务的任何人通过而不是子任务，则按预期的方式运行。然而，当两人都失败的时候，我就有了问题。在这种情况下，子任务被跳过而不是失败。下面是dag实现
import logging
from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.hive_operator import HiveOperator
from airflow.operators.bash_operator import BashOperator
from a
浏览 1提问于2020-10-30得票数 1
1回答
我们正在探索使用Apache Airflow来取代当前ETL的orchestrator工具。我们目前的ETL有600多个不同的任务，具有复杂的依赖关系。这些任务主要是对Informatica PowerCenter工作流的调用，但也有少量数据库过程和shell脚本 为了测试UI，我创建了一个包含600个任务的DAG。我没有使用我创建的实际自定义操作符，而是使用了开箱即用的BashOperator来打印日期，这是我能想到的最简单的命令。然后，我设置依赖项以匹配当前的ETL。有超过2000个依赖关系，但我将测试限制为大约1400个依赖关系。 import airflow
from airflow
浏览 21提问于2020-04-04得票数 2
我有一个由三个任务组成的Airflow工作流；第二个任务依赖于第一个任务，第三个任务依赖于第二个任务。
如果我通过then服务器运行DAG，则第一个任务完成，但随后开始重新运行，而不是触发第二个任务。要记住的一件事是，第一个任务确实需要130秒以上的时间来运行。这是因为第一个任务的持续时间造成的吗？
import airflow
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import timedelta, datetime
default_ar
浏览 59提问于2018-06-05得票数 0
回答已采纳
1回答
我正在尝试遵循Airflow 在DAG中使用变量。
这些变量是在Airflow UI中设置的，我使用这些变量创建了一个简单的DAG。加载文档中所示的变量会导致以下错误：
[2021-02-18 16:32:15,350] {variable.py:64} ERROR - Can't decrypt _val for key=foo, invalid token or value
[2021-02-18 16:32:15,364] {taskinstance.py:1396} ERROR - 'Variable foo does not exist'
下面是我正在使用的设
浏览 7提问于2021-02-19得票数 2
回答已采纳
我正在使用气流稳定舵图和Kubernetes Executor，新的pod正在为dag调度，但它与dag_id的故障无法找到问题。我正在使用git-sync来获取dags。下面是错误和kubernetes配置值。有人能帮我解决这个问题吗？
错误：
[2020-07-01 23:18:36,939] {__init__.py:51} INFO - Using executor LocalExecutor
[2020-07-01 23:18:36,940] {dagbag.py:396} INFO - Filling up the DagBag from /opt/airflow/dags/dag
浏览 9提问于2020-07-02得票数 6
1回答
我对气流很陌生。不过，我尝试删除气流中的某些DAG (手动删除，只使用底部)，但删除后得到消息(因此物理DAG不再存在)。
中断DAG: /usr/local/airflow/dags/reports_general/templates/data_quality_report_airflow__.py无效控制字符位于:第2行第116列(char 118)
有人知道怎么解决吗？
浏览 3提问于2022-03-13得票数 0
在我的本地机器上，我创建了一个虚拟环境并安装了Airflow。当dag或plugin需要python库时，我会通过pip将其安装到相同的virtualenv中。
如何跟踪哪些库属于dag，哪些库用于airflow本身？我最近删除了一个dag，并想移除它正在使用的库。这相当耗时，我祈祷我没有删除正在被另一个dag使用的东西！
浏览 5提问于2019-07-04得票数 9
1回答
我把达格安排在气流中10分钟什么也不做。
这是我的dags代码：
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date':datetime.now(),
浏览 2提问于2018-01-05得票数 0
回答已采纳
我面临一些问题，试图建立一个基本的DAG文件在气流(但我也有另外两个文件)。
我通过Ubuntu使用LocalExecutor，并将我的文件保存在“C：\Users\tdamasce\Documents\工作区”中，其中包含了dag和日志文件。
我的剧本是
# step 1 - libraries
from email.policy import default
from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.dummy_operator import DummyO
浏览 5提问于2022-03-24得票数 0
回答已采纳
1回答
我想得到这个DAG的默认args中提到的电子邮件，使用气流中的另一个DAG。我怎么能这么做？请帮帮忙，我是新来的气流！
from airflow.models import DagRun
from airflow.operators.python_operator import PythonOperator
from datetime import datetime, timedelta
from datetime import datetime, timedelta
from airflow import DAG
def first_function(**context):
pri
浏览 1提问于2022-06-10得票数 0
1回答
我需要把DAG的运行时间改为中午。我遵循了来自不同问题的建议，删除了DAG，并上传了一个带有新dag_id的重命名版本。尽管最初的DAG已从dag_1.py重命名为new_dag_1.py，但当我上传这个新的DAG版本时，dag_id更改了，日程间隔从'@daily‘更改为’012** *‘当我上传这个新的dag版本时，这个dag主页的计划部分仍然是'1天，0:00:00’。
我用这些参数上传了一个完全不同的DAG，调度间隔正确地显示了‘012** *’，所以更改的DAG中肯定有什么东西，或者是一些元数据，阻止气流将它视为新的。除了我更改的dag文件的名称和更改的dag_id之
浏览 19提问于2022-07-17得票数 0
回答已采纳
我希望能够从我的代码中发布和触发一个DAG对象，这个对象不受调度程序的控制(即。$AIRFLOW_HOME/dags文件夹)
最后，我将以编程方式创建一个py文件，其中包含我想要发布的DAG定义，并将该文件保存到$AIRFLOW_HOME/dags文件夹中。我相信应该比那简单多了。
下面是我尝试过的。
import airflow
from airflow import DAG
from datetime import timedelta
from airflow.models import DagPickle
from airflow.operators.dummy_operator im
浏览 1提问于2018-02-28得票数 0
回答已采纳
我有一个airflow dag，而我要做的是读取存储在airflow UI中的变量(用户名和密码)，并将这些变量值作为导出的值传递到操作系统中。原因是因为我使用的是dbt yml文件，它要求我读取环境变量'dbt_user‘。(另一种方法是在yaml文件中设置密码，这是不安全的。 default:
target: dev
outputs:
dev:
type: snowflake
account: xxxx
user: "{{ env_var('dbt_user') }}" 我尝试编写一个dag来执
浏览 114提问于2021-11-04得票数 0
4回答
我打开了气流，检查了连接，发现后面有太多的连接在运行。任何想法，如何杀死那些我不使用，或我想知道最低的conn_id运行它。
架构
LocalExecutor (与任何其他经纪人不同)
Postgres作为元数据
然而，它列出了17个连接。
以下是连接列表。
这是airflow.cfg。
[core]
# Thee home folder for airflow, default is ~/airflow
airflow_home = /usr/src/app
# The folder where your airflow pipelines live, most
浏览 4提问于2016-07-16得票数 21
回答已采纳
我正在尝试运行一个Airflow dag，它创建一个EMR集群，添加一些步骤，检查它们，最后终止创建的EMR集群。但是当我运行Airflow Dag时，它一直处于运行状态，没有显示任何错误或日志。 有人能告诉我我哪里做错了吗？是否有我应该添加的缺少的参数？或者是dag时间表的问题？ import airflow
from airflow import DAG
from airflow.contrib.operators.emr_create_job_flow_operator import
EmrCreateJobFlowOperator
from airflow.contrib.oper
浏览 16提问于2019-02-04得票数 3
我使用Ubuntu在运行Win 10的本地机器上设置了气流2.0。我使用PostgreSQL作为数据库，CeleryExecutor和RabbitMQ作为芹菜后端。我创建了一些DAG，每个DAG都通过SSH隧道连接到Redshift数据库，并执行SQL命令。当我手动触发或通过调度程序运行时，每个DAG都会顺利运行。
但是，当我为这些DAG同时开始运行设置日程时，我遇到了一个错误。例如，如果DAG1和DAG2在上午8:00开始运行，这2个dags将失败并显示如下错误：
or :服务器意外地关闭了连接，这可能意味着服务器在处理请求之前或处理过程中异常终止。
如果我在不同的时间设置这两个跳闸，一切
浏览 11提问于2021-01-12得票数 0
回答已采纳
我在Apache气流上创建了一个DAG。调度程序似乎被配置为从2015年6月开始运行(顺便提一下)。我不知道为什么，但是我创建了一个新的dag，我没有回填它，我只用这些日期间隔用不同的DAG ID回填其他DAG ID，调度器使用这些日期并回填我的新进程。我开始使用气流)。
(更新:我意识到DAG是回填的，因为开始日期是在DAG默认配置上设置的，尽管这并不能解释我在下面公开的行为)
从那天起，我试图停止调度程序来运行所有DAG执行。airflow backfill --mark_success tutorial2 -s '2015-06-01' -e '2019-02-2
浏览 0提问于2019-02-27得票数 10
回答已采纳
我正在使用apache-airflow==1.10.0
我得到的错误如下所示：
sqlalchemy.exc.ProgrammingError: (psycopg2.ProgrammingError) relation "variable" does not exist
LINE 2: FROM variable
当我声明如下任务时：
from airflow.models import Variable
dag = DAG('dag')
PythonOperator('task_id', ratio=Variable.get('r
浏览 1提问于2018-12-21得票数 5
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
