File tree Expand file tree Collapse file tree 6 files changed +9
-15
lines changed
packages/core/minos-microservice-networks
test_brokers/test_handlers Expand file tree Collapse file tree 6 files changed +9
-15
lines changed Original file line number Diff line number Diff line change 99 BrokerClientPool ,
1010 BrokerDispatcher ,
1111 BrokerHandler ,
12- BrokerPort ,
1312 BrokerHandlerService ,
1413 BrokerMessage ,
1514 BrokerMessageV1 ,
1615 BrokerMessageV1Payload ,
1716 BrokerMessageV1Status ,
1817 BrokerMessageV1Strategy ,
18+ BrokerPort ,
1919 BrokerPublisher ,
2020 BrokerPublisherBuilder ,
2121 BrokerPublisherQueue ,
121121)
122122from .scheduling import (
123123 CronTab ,
124+ PeriodicPort ,
124125 PeriodicTask ,
125126 PeriodicTaskScheduler ,
126- PeriodicPort ,
127127 PeriodicTaskSchedulerService ,
128128 ScheduledRequest ,
129129 ScheduledRequestContent ,
Original file line number Diff line number Diff line change 1515)
1616from .handlers import (
1717 BrokerHandler ,
18- BrokerPort ,
1918 BrokerHandlerService ,
19+ BrokerPort ,
2020)
2121from .messages import (
2222 REQUEST_HEADERS_CONTEXT_VAR ,
Original file line number Diff line number Diff line change 22 BrokerHandler ,
33)
44from .ports import (
5- BrokerPort ,
65 BrokerHandlerService ,
6+ BrokerPort ,
77)
Original file line number Diff line number Diff line change @@ -49,7 +49,5 @@ class BrokerHandlerService(BrokerPort):
4949 """Broker Handler Service class."""
5050
5151 def __init__ (self , ** kwargs ):
52- warnings .warn (
53- f"{ BrokerHandlerService !r} has been deprecated. Use { BrokerPort } instead." , DeprecationWarning
54- )
52+ warnings .warn (f"{ BrokerHandlerService !r} has been deprecated. Use { BrokerPort } instead." , DeprecationWarning )
5553 super ().__init__ (** kwargs )
Original file line number Diff line number Diff line change 1212)
1313from minos .networks import (
1414 BrokerHandler ,
15- BrokerPort ,
1615 BrokerHandlerService ,
16+ BrokerPort ,
1717 InMemoryBrokerPublisher ,
1818 InMemoryBrokerSubscriberBuilder ,
1919)
@@ -35,15 +35,11 @@ def test_is_instance(self):
3535 self .assertIsInstance (service , Port )
3636
3737 def test_handler (self ):
38- service = BrokerPort (
39- config = self .config , publisher = self .publisher , subscriber_builder = self .subscriber_builder
40- )
38+ service = BrokerPort (config = self .config , publisher = self .publisher , subscriber_builder = self .subscriber_builder )
4139 self .assertIsInstance (service .handler , BrokerHandler )
4240
4341 async def test_start_stop (self ):
44- service = BrokerPort (
45- config = self .config , publisher = self .publisher , subscriber_builder = self .subscriber_builder
46- )
42+ service = BrokerPort (config = self .config , publisher = self .publisher , subscriber_builder = self .subscriber_builder )
4743
4844 setup_mock = AsyncMock ()
4945 destroy_mock = AsyncMock ()
Original file line number Diff line number Diff line change 1111 PostgresAsyncTestCase ,
1212)
1313from minos .networks import (
14- PeriodicTaskScheduler ,
1514 PeriodicPort ,
15+ PeriodicTaskScheduler ,
1616 PeriodicTaskSchedulerService ,
1717)
1818from tests .utils import (
You can’t perform that action at this time.
0 commit comments