summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTakashi Kajinami <tkajinam@redhat.com>2021-11-29 13:46:09 +0900
committerTakashi Kajinami <tkajinam@redhat.com>2021-11-29 14:30:04 +0900
commit86bfa272c5129796642d3614d8c8ed33dd9d094e (patch)
tree9966f6a2a84f2da3d900ef5817270ed153951412
parent6d9330a1b0afaa1fdb8c995c009b4ac90db94c00 (diff)
downloadtaskflow-86bfa272c5129796642d3614d8c8ed33dd9d094e.tar.gz
Use LOG.warning instead of deprecated LOG.warn
The LOG.warn method is deprecated[1] and the LOG.warning method should be used instead. [1] https://docs.python.org/3/library/logging.html#logging.warning Change-Id: I4321a489c56eb1aa650e776ee35d8f88d4d8910c
-rw-r--r--taskflow/engines/worker_based/server.py4
-rw-r--r--taskflow/tests/unit/worker_based/test_server.py2
2 files changed, 3 insertions, 3 deletions
diff --git a/taskflow/engines/worker_based/server.py b/taskflow/engines/worker_based/server.py
index fe51831..7842ed5 100644
--- a/taskflow/engines/worker_based/server.py
+++ b/taskflow/engines/worker_based/server.py
@@ -164,8 +164,8 @@ class Server(object):
# in the first place...).
reply_to, task_uuid = self._parse_message(message)
except ValueError:
- LOG.warn("Failed to parse request attributes from message '%s'",
- ku.DelayedPretty(message), exc_info=True)
+ LOG.warning("Failed to parse request attributes from message '%s'",
+ ku.DelayedPretty(message), exc_info=True)
return
else:
# prepare reply callback
diff --git a/taskflow/tests/unit/worker_based/test_server.py b/taskflow/tests/unit/worker_based/test_server.py
index e3276d8..5380204 100644
--- a/taskflow/tests/unit/worker_based/test_server.py
+++ b/taskflow/tests/unit/worker_based/test_server.py
@@ -213,7 +213,7 @@ class TestServer(test.MockTestCase):
]
self.master_mock.assert_has_calls(master_mock_calls)
- @mock.patch("taskflow.engines.worker_based.server.LOG.warn")
+ @mock.patch("taskflow.engines.worker_based.server.LOG.warning")
def test_process_request_parse_message_failure(self, mocked_exception):
self.message_mock.properties = {}
request = self.make_request()