File tree Expand file tree Collapse file tree 3 files changed +28
-0
lines changed
Expand file tree Collapse file tree 3 files changed +28
-0
lines changed Original file line number Diff line number Diff line change 22
33import inspect
44import logging
5+ import warnings
56
67import crochet
78from twisted .internet import defer , reactor , threads
@@ -262,6 +263,16 @@ def twisted_publish(message, exchange=None):
262263 raise
263264
264265
266+ def _twisted_publish (message , exchange ):
267+ """Deprecated method, use _twisted_publish_wrapper()."""
268+ warnings .warn (
269+ "_twisted_publish() is deprecated, use _twisted_publish_wrapper(); version 3.6.0" ,
270+ DeprecationWarning ,
271+ stacklevel = 2 ,
272+ )
273+ return _twisted_publish_wrapper (message , exchange )
274+
275+
265276@crochet .run_in_reactor
266277@defer .inlineCallbacks
267278def _twisted_publish_wrapper (message , exchange ):
Original file line number Diff line number Diff line change 1+ Add back api._twisted_publish as deprecated method and emit proper warning when it is used
Original file line number Diff line number Diff line change @@ -222,6 +222,22 @@ def test_publish_to_exchange(self):
222222
223223 mock_twisted_publish .assert_called_once_with (message , exchange )
224224
225+ @mock .patch ("warnings.warn" )
226+ def test_deprecated_twisted_publish (self , warn ):
227+ """Assert calling the deprecated method emits warning."""
228+ message = "test_message"
229+ exchange = "test_exchange"
230+
231+ with mock .patch ("fedora_messaging.api._twisted_publish_wrapper" ) as mock_twisted_publish :
232+ api ._twisted_publish (message , exchange )
233+
234+ warn .assert_called_once_with (
235+ "_twisted_publish() is deprecated, use _twisted_publish_wrapper(); version 3.6.0" ,
236+ DeprecationWarning ,
237+ stacklevel = 2 ,
238+ )
239+ mock_twisted_publish .assert_called_once_with (message , exchange )
240+
225241 @pytest_twisted .inlineCallbacks
226242 def test_publish_failed (self ):
227243 """Assert an exception is raised when message can't be published."""
You can’t perform that action at this time.
0 commit comments