小编cho*_*433的帖子

整个DAG的气流depends_on_past

有没有一种方法可以使用depends_on_past整个DagRun,而不仅仅是应用于任务?

我有一个每日DAG,而周五DagRun在第四个任务上出错,但周六和周日DagRuns仍按计划进行.使用depends_on_past = True会在相同的第4个任务上暂停DagRun,但前3个任务仍然会运行.

我可以在DagRun DB表中看到有一个state包含failedFriday DagRun 的列.我想要的是一种方法,如果前一个DagRun失败,配置DagRun不启动,在找到之前失败的任务之前不启动和运行.

有谁知道这是否可能?

airflow apache-airflow airflow-scheduler

6
推荐指数
3
解决办法
5936
查看次数

Flask-Admin 找不到反向关系

我已经有一个使用我的 SQLAlchemy 模型的应用程序,我现在正在尝试在顶部添加一个 Flask 管理网站来管理数据库中的一些数据。这个模型已经在整个现有应用程序中设置和工作,所以我知道关系配置正确。在我的数据库中,data_package 表对供应商表有一个 FK,这已作为关系添加。但是,当我创建一个烧瓶模型视图以允许编辑 data_package 时,我收到了错误:

例外:找不到模型的反向关系

我添加了下面代码的一个子集,还有更多的列和逻辑,但这是我必须尝试和测试问题修复程序的最低限度。问题发生是因为我添加了inline_models = (Supplier, )这是我需要的,因为我想选择允许更改数据包的供应商。

抛出异常的代码行是https://github.com/flask-admin/flask-admin/blob/master/flask_admin/contrib/sqla/form.py#L558。这样做的原因是关系方向被定义为 ONETOMANY,并且有一个检查以确保方向是 MANYTOONE 或 MANYTOMANY

Base = declarative_base()


class Supplier(Base):
    __tablename__ = 'supplier'
    id = Column(Integer, primary_key=True)
    name = Column(String(100), nullable=False)

class DataPackage(Base):
    __tablename__ = 'data_package'
    id = Column(Integer, primary_key=True)
    name = Column(String(100), nullable=False)

    supplier_id = Column(Integer, ForeignKey('supplier.id'), index=True, nullable=False)
    supplier = relationship("Supplier", backref='packages')

class DataPackageAdminView(ModelViewOnly):
    form_columns = ['name', 'supplier']
    inline_models = (Supplier,)

def create_app():
    settings.configure_orm()

    app = Flask(__name__)
    app.config.from_pyfile('config.py')

    @app.route('/')
    def …
Run Code Online (Sandbox Code Playgroud)

sqlalchemy flask flask-sqlalchemy flask-admin

5
推荐指数
0
解决办法
1301
查看次数