seanxwzhang commented on a change in pull request #8545:
URL: https://github.com/apache/airflow/pull/8545#discussion_r428375456
##
File path: airflow/models/dagrun.py
##
@@ -491,6 +491,25 @@ def is_backfill(self):
seanxwzhang commented on a change in pull request #8545:
URL: https://github.com/apache/airflow/pull/8545#discussion_r418414577
##
File path: airflow/models/baseoperator.py
##
@@ -392,10 +442,79 @@ def __init__(
% (self.task_id, dag.dag_id))
seanxwzhang commented on a change in pull request #8545:
URL: https://github.com/apache/airflow/pull/8545#discussion_r418404338
##
File path: airflow/utils/sla.py
##
@@ -0,0 +1,500 @@
+# Licensed to the Apache Software Foundation (ASF) under one
Review comment:
sure,
seanxwzhang commented on a change in pull request #8545:
URL: https://github.com/apache/airflow/pull/8545#discussion_r418254475
##
File path: airflow/models/baseoperator.py
##
@@ -392,10 +442,79 @@ def __init__(
% (self.task_id, dag.dag_id))
seanxwzhang commented on a change in pull request #8545:
URL: https://github.com/apache/airflow/pull/8545#discussion_r418201150
##
File path: airflow/jobs/scheduler_job.py
##
@@ -750,7 +600,16 @@ def _process_dags(self, dags: List[DAG], session=None):
if
seanxwzhang commented on a change in pull request #8545:
URL: https://github.com/apache/airflow/pull/8545#discussion_r415941751
##
File path: airflow/models/dag.py
##
@@ -1582,6 +1580,196 @@ def sync_to_db(self, sync_time=None, session=None):
"""
