diff --git a/taskflow/engines/action_engine/actions/retry.py b/taskflow/engines/action_engine/actions/retry.py index 49dd94ac8..d7f69c8c2 100644 --- a/taskflow/engines/action_engine/actions/retry.py +++ b/taskflow/engines/action_engine/actions/retry.py @@ -15,13 +15,10 @@ # under the License. from taskflow.engines.action_engine.actions import base -from taskflow import logging from taskflow import retry as retry_atom from taskflow import states from taskflow.types import failure -LOG = logging.getLogger(__name__) - class RetryAction(base.Action): """An action that handles executing, state changes, ... of retry atoms.""" diff --git a/taskflow/engines/action_engine/executor.py b/taskflow/engines/action_engine/executor.py index 9e5c6f929..5dbaf58e3 100644 --- a/taskflow/engines/action_engine/executor.py +++ b/taskflow/engines/action_engine/executor.py @@ -19,7 +19,6 @@ import abc import futurist import six -from taskflow import logging from taskflow import task as ta from taskflow.types import failure from taskflow.types import notifier @@ -28,8 +27,6 @@ from taskflow.types import notifier EXECUTED = 'executed' REVERTED = 'reverted' -LOG = logging.getLogger(__name__) - def _execute_retry(retry, arguments): try: diff --git a/taskflow/persistence/models.py b/taskflow/persistence/models.py index 8e79d2a54..7b08f4e5b 100644 --- a/taskflow/persistence/models.py +++ b/taskflow/persistence/models.py @@ -24,13 +24,10 @@ from oslo_utils import uuidutils import six from taskflow import exceptions as exc -from taskflow import logging from taskflow import states from taskflow.types import failure as ft from taskflow.utils import misc -LOG = logging.getLogger(__name__) - # Internal helpers...