小编sub*_*bba的帖子

Airflow:如何删除DAG?

我已经启动了Airflow网络服务器并安排了一些dags.我可以在Web GUI上看到这些dags.

如何删除特定DAG在Web GUI中运行和显示?是否有Airflow CLI命令来执行此操作?

我环顾四周,但是一旦加载和安排DAG,就找不到简单的删除DAG的方法.

airflow

60
推荐指数
7
解决办法
4万
查看次数

Airflow:PythonOperator:为什么要包含'ds'arg?

在定义一个稍后用作python_callable的函数时,为什么'ds'被包含在函数的第一个arg中?

例如:

def python_func(ds, **kwargs):
    pass
Run Code Online (Sandbox Code Playgroud)

我查看了Airflow文档,但找不到任何解释.

airflow

14
推荐指数
1
解决办法
1万
查看次数

Python:为什么重新定义函数不是错误?有这种功能的hackish方式?

例如:

def foo():
    print 'first foo'
def foo():
    print 'second foo'

foo()
Run Code Online (Sandbox Code Playgroud)

默默地产生: second foo

今天我在同一个文件中复制/粘贴了一个函数定义,并在第二个定义的主体中更改了几行,但忘了更改函数名本身.我长时间挠头看着输出,我花了一段时间才弄明白.

如何强制解释器在重新定义函数时至少抛出一个警告?提前致谢.

python

3
推荐指数
1
解决办法
3206
查看次数

标签 统计

airflow ×2

python ×1