From b93f4c661fe7c679cab1dd0a590edcf1a9aa5be1 Mon Sep 17 00:00:00 2001 From: "Ivan A. Melnikov" Date: Tue, 18 Mar 2014 11:00:40 +0400 Subject: [PATCH] Fix few minor spelling errors Change-Id: I68082263189435af22d2bd6a63cc1ec77419668d --- taskflow/examples/resume_from_backend.py | 2 +- taskflow/persistence/backends/impl_zookeeper.py | 2 +- taskflow/retry.py | 2 +- taskflow/states.py | 2 +- taskflow/tests/unit/test_retries.py | 2 +- taskflow/utils/kazoo_utils.py | 2 +- 6 files changed, 6 insertions(+), 6 deletions(-) diff --git a/taskflow/examples/resume_from_backend.py b/taskflow/examples/resume_from_backend.py index ed8192b3..6e270408 100644 --- a/taskflow/examples/resume_from_backend.py +++ b/taskflow/examples/resume_from_backend.py @@ -45,7 +45,7 @@ import example_utils # noqa # # Usage: # -# With a filesytem directory as backend +# With a filesystem directory as backend # # python taskflow/examples/resume_from_backend.py # diff --git a/taskflow/persistence/backends/impl_zookeeper.py b/taskflow/persistence/backends/impl_zookeeper.py index 73401d9a..860a998d 100644 --- a/taskflow/persistence/backends/impl_zookeeper.py +++ b/taskflow/persistence/backends/impl_zookeeper.py @@ -365,7 +365,7 @@ class ZkConnection(base.Connection): _destroy_logbook(lb_uuid, txn) def clear_all(self, delete_dirs=True): - """Delete all data transactioanlly.""" + """Delete all data transactionally.""" with self._exc_wrapper(): with self._client.transaction() as txn: diff --git a/taskflow/retry.py b/taskflow/retry.py index d1ce6b05..5281a308 100644 --- a/taskflow/retry.py +++ b/taskflow/retry.py @@ -83,7 +83,7 @@ class Retry(atom.Atom): """On subflow failure makes a decision about the future flow execution using information about all previous failures. Returns retry action constant: - 'RERTY' when subflow must be reverted and restarted again (maybe + 'RETRY' when subflow must be reverted and restarted again (maybe with new parameters). 'REVERT' when this subflow must be completely reverted and parent subflow should make a decision about the flow execution. diff --git a/taskflow/states.py b/taskflow/states.py index 14893857..2d314776 100644 --- a/taskflow/states.py +++ b/taskflow/states.py @@ -32,7 +32,7 @@ SUSPENDING = 'SUSPENDING' SUSPENDED = 'SUSPENDED' RESUMING = 'RESUMING' -# Task states (mainaly a subset of the flow states). +# Task states (mainly a subset of the flow states). FAILURE = FAILURE PENDING = PENDING REVERTED = REVERTED diff --git a/taskflow/tests/unit/test_retries.py b/taskflow/tests/unit/test_retries.py index 45e794eb..39308362 100644 --- a/taskflow/tests/unit/test_retries.py +++ b/taskflow/tests/unit/test_retries.py @@ -548,7 +548,7 @@ class RetryTest(utils.EngineTestBase): engine.storage.inject({'values': values, 'y': 1}) self.assertRaisesRegexp(exc.NotFound, '^No elements left', engine.run) - def test_retry_after_failure_before_processig_failure(self): + def test_retry_after_failure_before_processing_failure(self): flow = uf.Flow('flow-1', retry.Times(3, provides='x')).add( utils.SaveOrderTask('task1')) engine = self._make_engine(flow) diff --git a/taskflow/utils/kazoo_utils.py b/taskflow/utils/kazoo_utils.py index ddf6bf62..a2b5390c 100644 --- a/taskflow/utils/kazoo_utils.py +++ b/taskflow/utils/kazoo_utils.py @@ -46,7 +46,7 @@ def finalize_client(client): def check_compatible(client, min_version=None, max_version=None): - """Checks if a kazook client is backed by a zookeeper server version + """Checks if a kazoo client is backed by a zookeeper server version that satisfies a given min (inclusive) and max (inclusive) version range. """ server_version = None