You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/02/09 09:08:11 UTC
incubator-airflow git commit: [AIRFLOW-2083] Docs: Use "its" instead
of "it's" where appropriate
Repository: incubator-airflow
Updated Branches:
refs/heads/master 2920d0475 -> 15b8a36b9
[AIRFLOW-2083] Docs: Use "its" instead of "it's" where appropriate
Closes #3020 from wrp/spelling
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/15b8a36b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/15b8a36b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/15b8a36b
Branch: refs/heads/master
Commit: 15b8a36b9011166b06f176f684b71703a4aebddd
Parents: 2920d04
Author: William Pursell <wi...@wepay.com>
Authored: Fri Feb 9 10:08:06 2018 +0100
Committer: Fokko Driesprong <fo...@godatadriven.com>
Committed: Fri Feb 9 10:08:06 2018 +0100
----------------------------------------------------------------------
airflow/bin/cli.py | 2 +-
airflow/contrib/hooks/redshift_hook.py | 2 +-
airflow/jobs.py | 6 +++---
airflow/ti_deps/deps/trigger_rule_dep.py | 2 +-
airflow/utils/dates.py | 2 +-
airflow/www/views.py | 10 ++++++----
docs/plugins.rst | 2 +-
tests/jobs.py | 2 +-
8 files changed, 15 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/15b8a36b/airflow/bin/cli.py
----------------------------------------------------------------------
diff --git a/airflow/bin/cli.py b/airflow/bin/cli.py
index 6bfcdcc..424fcda 100755
--- a/airflow/bin/cli.py
+++ b/airflow/bin/cli.py
@@ -1572,7 +1572,7 @@ class CLIFactory(object):
'func': test,
'help': (
"Test a task instance. This will run a task without checking for "
- "dependencies or recording it's state in the database."),
+ "dependencies or recording its state in the database."),
'args': (
'dag_id', 'task_id', 'execution_date', 'subdir', 'dry_run',
'task_params'),
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/15b8a36b/airflow/contrib/hooks/redshift_hook.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/hooks/redshift_hook.py b/airflow/contrib/hooks/redshift_hook.py
index 70a4854..baa11e7 100644
--- a/airflow/contrib/hooks/redshift_hook.py
+++ b/airflow/contrib/hooks/redshift_hook.py
@@ -79,7 +79,7 @@ class RedshiftHook(AwsHook):
def restore_from_cluster_snapshot(self, cluster_identifier, snapshot_identifier):
"""
- Restores a cluster from it's snapshot
+ Restores a cluster from its snapshot
:param cluster_identifier: unique identifier of a cluster
:type cluster_identifier: str
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/15b8a36b/airflow/jobs.py
----------------------------------------------------------------------
diff --git a/airflow/jobs.py b/airflow/jobs.py
index 172792d..35a3fb6 100644
--- a/airflow/jobs.py
+++ b/airflow/jobs.py
@@ -68,7 +68,7 @@ class BaseJob(Base, LoggingMixin):
"""
Abstract class to be derived for jobs. Jobs are processing items with state
and duration that aren't task instances. For instance a BackfillJob is
- a collection of task instance runs, but should have it's own state, start
+ a collection of task instance runs, but should have its own state, start
and end time.
"""
@@ -1796,8 +1796,8 @@ class SchedulerJob(BaseJob):
dep_context = DepContext(deps=QUEUE_DEPS, ignore_task_deps=True)
# Only schedule tasks that have their dependencies met, e.g. to avoid
- # a task that recently got it's state changed to RUNNING from somewhere
- # other than the scheduler from getting it's state overwritten.
+ # a task that recently got its state changed to RUNNING from somewhere
+ # other than the scheduler from getting its state overwritten.
# TODO(aoen): It's not great that we have to check all the task instance
# dependencies twice; once to get the task scheduled, and again to actually
# run the task. We should try to come up with a way to only check them once.
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/15b8a36b/airflow/ti_deps/deps/trigger_rule_dep.py
----------------------------------------------------------------------
diff --git a/airflow/ti_deps/deps/trigger_rule_dep.py b/airflow/ti_deps/deps/trigger_rule_dep.py
index 5a80314..30a5a13 100644
--- a/airflow/ti_deps/deps/trigger_rule_dep.py
+++ b/airflow/ti_deps/deps/trigger_rule_dep.py
@@ -127,7 +127,7 @@ class TriggerRuleDep(BaseTIDep):
"total": upstream, "successes": successes, "skipped": skipped,
"failed": failed, "upstream_failed": upstream_failed, "done": done
}
- # TODO(aoen): Ideally each individual trigger rules would be it's own class, but
+ # TODO(aoen): Ideally each individual trigger rules would be its own class, but
# this isn't very feasible at the moment since the database queries need to be
# bundled together for efficiency.
# handling instant state assignment based on trigger rules
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/15b8a36b/airflow/utils/dates.py
----------------------------------------------------------------------
diff --git a/airflow/utils/dates.py b/airflow/utils/dates.py
index 2ca2b2c..aceb426 100644
--- a/airflow/utils/dates.py
+++ b/airflow/utils/dates.py
@@ -146,7 +146,7 @@ def round_time(dt, delta, start_date=timezone.make_aware(datetime.min)):
# We are looking for a datetime in the form start_date + i * delta
# which is as close as possible to dt. Since delta could be a relative
- # delta we don't know it's exact length in seconds so we cannot rely on
+ # delta we don't know its exact length in seconds so we cannot rely on
# division to find i. Instead we employ a binary search algorithm, first
# finding an upper and lower limit and then disecting the interval until
# we have found the closest match.
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/15b8a36b/airflow/www/views.py
----------------------------------------------------------------------
diff --git a/airflow/www/views.py b/airflow/www/views.py
index 89641e9..a41f5fe 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -811,10 +811,12 @@ class Airflow(BaseView):
- The scheduler is down or under heavy load<br/>
{}
<br/>
- If this task instance does not start soon please contact your Airflow administrator for assistance."""
- .format(
- "- This task instance already ran and had it's state changed manually (e.g. cleared in the UI)<br/>"
- if ti.state == State.NONE else "")))]
+ If this task instance does not start soon please contact your Airflow """
+ """administrator for assistance."""
+ .format(
+ "- This task instance already ran and had its state changed "
+ "manually (e.g. cleared in the UI)<br/>"
+ if ti.state == State.NONE else "")))]
# Use the scheduler's context to figure out which dependencies are not met
dep_context = DepContext(SCHEDULER_DEPS)
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/15b8a36b/docs/plugins.rst
----------------------------------------------------------------------
diff --git a/docs/plugins.rst b/docs/plugins.rst
index 8d2078f..9fb9c0e 100644
--- a/docs/plugins.rst
+++ b/docs/plugins.rst
@@ -41,7 +41,7 @@ Airflow has many components that can be reused when building an application:
* A metadata database to store your models
* Access to your databases, and knowledge of how to connect to them
* An array of workers that your application can push workload to
-* Airflow is deployed, you can just piggy back on it's deployment logistics
+* Airflow is deployed, you can just piggy back on its deployment logistics
* Basic charting capabilities, underlying libraries and abstractions
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/15b8a36b/tests/jobs.py
----------------------------------------------------------------------
diff --git a/tests/jobs.py b/tests/jobs.py
index b2ca15e..5771bf1 100644
--- a/tests/jobs.py
+++ b/tests/jobs.py
@@ -2548,7 +2548,7 @@ class SchedulerJobTest(unittest.TestCase):
def test_dag_get_active_runs(self):
"""
- Test to check that a DAG returns it's active runs
+ Test to check that a DAG returns its active runs
"""
now = timezone.utcnow()