You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ka...@apache.org on 2021/11/10 23:56:40 UTC
[airflow] branch main updated: Fix DAG docstrings (#19531)
This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new deaa9a3 Fix DAG docstrings (#19531)
deaa9a3 is described below
commit deaa9a36242aabf958ce1d78776d2f29bfc416f4
Author: Jed Cunningham <66...@users.noreply.github.com>
AuthorDate: Wed Nov 10 16:56:11 2021 -0700
Fix DAG docstrings (#19531)
---
airflow/models/dag.py | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/airflow/models/dag.py b/airflow/models/dag.py
index 78ad452..0c28c41 100644
--- a/airflow/models/dag.py
+++ b/airflow/models/dag.py
@@ -687,13 +687,13 @@ class DAG(LoggingMixin):
"""Get information about the next DagRun of this dag after ``date_last_automated_dagrun``.
This calculates what time interval the next DagRun should operate on
- (its execution date), and when it can be scheduled, , according to the
+ (its execution date) and when it can be scheduled, according to the
dag's timetable, start_date, end_date, etc. This doesn't check max
active run or any other "max_active_tasks" type limits, but only
performs calculations based on the various date and interval fields of
this dag and its tasks.
- :param date_last_automated_dagrun: The ``max(execution_date)`` of
+ :param last_automated_dagrun: The ``max(execution_date)`` of
existing "automated" DagRuns for this dag (scheduled or backfill,
but not manual).
:param restricted: If set to *False* (default is *True*), ignore
@@ -2903,7 +2903,8 @@ class DagModel(Base):
Calculate ``next_dagrun`` and `next_dagrun_create_after``
:param dag: The DAG object
- :param most_recent_dag_run: DateTime of most recent run of this dag, or none if not yet scheduled.
+ :param most_recent_dag_run: DataInterval (or datetime) of most recent run of this dag, or none
+ if not yet scheduled.
"""
if isinstance(most_recent_dag_run, datetime):
warnings.warn(