Merge "Fix few minor spelling errors"

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
 #

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:
 

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.

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

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)

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