Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id B4FF0200C50 for ; Sat, 25 Mar 2017 01:28:16 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id B39BA160B96; Sat, 25 Mar 2017 00:28:16 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id D068F160B93 for ; Sat, 25 Mar 2017 01:28:15 +0100 (CET) Received: (qmail 85615 invoked by uid 500); 25 Mar 2017 00:28:15 -0000 Mailing-List: contact commits-help@airflow.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airflow.incubator.apache.org Delivered-To: mailing list commits@airflow.incubator.apache.org Received: (qmail 85604 invoked by uid 99); 25 Mar 2017 00:28:15 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 25 Mar 2017 00:28:14 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 9A3F5C1A89 for ; Sat, 25 Mar 2017 00:28:14 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.222 X-Spam-Level: X-Spam-Status: No, score=-4.222 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id BvsCA0sq0gJp for ; Sat, 25 Mar 2017 00:28:13 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id 8BF625FAD1 for ; Sat, 25 Mar 2017 00:28:12 +0000 (UTC) Received: (qmail 85516 invoked by uid 99); 25 Mar 2017 00:28:11 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 25 Mar 2017 00:28:11 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 7E946DFE1E; Sat, 25 Mar 2017 00:28:11 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: jlowin@apache.org To: commits@airflow.incubator.apache.org Message-Id: <0cc7bcccb7cf48dd906d47607f5ce6ea@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: incubator-airflow git commit: [AIRFLOW-1040] Fix some small typos in comments and docstrings Date: Sat, 25 Mar 2017 00:28:11 +0000 (UTC) archived-at: Sat, 25 Mar 2017 00:28:16 -0000 Repository: incubator-airflow Updated Branches: refs/heads/master b2b9587cc -> d8c0f59d5 [AIRFLOW-1040] Fix some small typos in comments and docstrings Closes #2174 from mschmo/fix-some-typos-models Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/d8c0f59d Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/d8c0f59d Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/d8c0f59d Branch: refs/heads/master Commit: d8c0f59d5d627efb65b47264d5169e3626195839 Parents: b2b9587 Author: Matthew Schmoyer Authored: Fri Mar 24 20:28:03 2017 -0400 Committer: Jeremiah Lowin Committed: Fri Mar 24 20:28:03 2017 -0400 ---------------------------------------------------------------------- airflow/models.py | 32 +++++++++++++++----------------- 1 file changed, 15 insertions(+), 17 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/d8c0f59d/airflow/models.py ---------------------------------------------------------------------- diff --git a/airflow/models.py b/airflow/models.py index df23de2..9d560fb 100755 --- a/airflow/models.py +++ b/airflow/models.py @@ -726,7 +726,7 @@ class TaskInstance(Base): authority and single source of truth around what tasks have run and the state they are in. - The SqlAchemy model doesn't have a SqlAlchemy foreign key to the task or + The SqlAlchemy model doesn't have a SqlAlchemy foreign key to the task or dag model deliberately to have more control over transactions. Database transactions on this table should insure double triggers and @@ -886,7 +886,7 @@ class TaskInstance(Base): :type execution_date: datetime :param mark_success: Whether to mark the task as successful :type mark_success: bool - :param ignore_all_deps: Ignore all ignoreable dependencies. + :param ignore_all_deps: Ignore all ignorable dependencies. Overrides the other ignore_* parameters. :type ignore_all_deps: boolean :param ignore_depends_on_past: Ignore depends_on_past parameter of DAGs @@ -1241,7 +1241,7 @@ class TaskInstance(Base): """ Runs the task instance. - :param verbose: whether to turn on more verbose loggin + :param verbose: whether to turn on more verbose logging :type verbose: boolean :param ignore_all_deps: Ignore all of the non-critical dependencies, just runs :type ignore_all_deps: boolean @@ -1883,9 +1883,9 @@ class BaseOperator(object): objects to the task instance and is documented under the macros section of the API. :type on_failure_callback: callable - :param on_retry_callback: much like the ``on_failure_callback`` excepts + :param on_retry_callback: much like the ``on_failure_callback`` except that it is executed when retries occur. - :param on_success_callback: much like the ``on_failure_callback`` excepts + :param on_success_callback: much like the ``on_failure_callback`` except that it is executed when the task succeeds. :type on_success_callback: callable :param trigger_rule: defines the rule by which dependencies are applied @@ -1905,7 +1905,7 @@ class BaseOperator(object): # For derived classes to define which fields will get jinjaified template_fields = [] - # Defines wich files extensions to look for in the templated fields + # Defines which files extensions to look for in the templated fields template_ext = [] # Defines the color in the UI ui_color = '#fff' @@ -2158,7 +2158,7 @@ class BaseOperator(object): """ Returns the list of dependencies for the operator. These differ from execution context dependencies in that they are specific to tasks and can be - extended/overriden by subclasses. + extended/overridden by subclasses. """ return { NotInRetryPeriodDep(), @@ -2817,7 +2817,7 @@ class DAG(BaseDag, LoggingMixin): """ Returns the last dag run for this dag, None if there was none. Last dag run can be any type of run eg. scheduled or backfilled. - Overriden DagRuns are ignored + Overridden DagRuns are ignored """ DR = DagRun qry = session.query(DR).filter( @@ -3064,7 +3064,7 @@ class DAG(BaseDag, LoggingMixin): Heavily inspired by: http://blog.jupo.org/2012/04/06/topological-sorting-acyclic-directed-graphs/ - :returns: list of tasks in topological order + :return: list of tasks in topological order """ # copy the the tasks so we leave it unmodified @@ -3315,8 +3315,8 @@ class DAG(BaseDag, LoggingMixin): """ Add a list of tasks to the DAG - :param task: a lit of tasks you want to add - :type task: list of tasks + :param tasks: a lit of tasks you want to add + :type tasks: list of tasks """ for task in tasks: self.add_task(task) @@ -3604,10 +3604,10 @@ class Variable(Base): :param key: Dict key for this Variable :type key: String - :param: default: Default value to set and return if the variable + :param default: Default value to set and return if the variable isn't already in the DB - :type: default: Mixed - :param: deserialize_json: Store this as a JSON encoded value in the DB + :type default: Mixed + :param deserialize_json: Store this as a JSON encoded value in the DB and un-encode it when retrieving a value :return: Mixed """ @@ -3827,8 +3827,6 @@ class DagStat(Base): :param dag_ids: dag_ids that may be dirty :type dag_ids: list - :param full_query: whether to check dag_runs for new drs not in dag_stats - :type full_query: bool """ # avoid querying with an empty IN clause if not dag_ids: @@ -4059,7 +4057,7 @@ class DagRun(Base): """ Determines the overall state of the DagRun based on the state of its TaskInstances. - :returns State: + :return: State """ dag = self.get_dag()