Skip to content
Snippets Groups Projects
Commit 94dea8b7 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

SW-811: adaptations to removed 'queue' parameter

parent 4f42b236
No related branches found
No related tags found
1 merge request!59Merge LOFAR-Release-4_0 into master
...@@ -92,7 +92,7 @@ class QABusListener(BusListener): ...@@ -92,7 +92,7 @@ class QABusListener(BusListener):
if not issubclass(handler_type, QAEventMessageHandler): if not issubclass(handler_type, QAEventMessageHandler):
raise TypeError("handler_type should be a QAEventMessageHandler subclass") raise TypeError("handler_type should be a QAEventMessageHandler subclass")
super().__init__(handler_type, handler_kwargs, exchange, routing_key, None, num_threads, broker) super().__init__(handler_type, handler_kwargs, exchange, routing_key, num_threads, broker)
__all__ = ["QABusListener", "QAEventMessageHandler"] __all__ = ["QABusListener", "QAEventMessageHandler"]
...@@ -91,7 +91,7 @@ class RABusListener(BusListener): ...@@ -91,7 +91,7 @@ class RABusListener(BusListener):
RABusListener listens on the lofar notification message bus and calls (empty) on<SomeMessage> methods when such a message is received. RABusListener listens on the lofar notification message bus and calls (empty) on<SomeMessage> methods when such a message is received.
Typical usage is to derive your own subclass from RABusListener and implement the specific on<SomeMessage> methods that you are interested in. Typical usage is to derive your own subclass from RABusListener and implement the specific on<SomeMessage> methods that you are interested in.
""" """
super().__init__(handler_type, handler_kwargs, exchange, routing_key, None, num_threads, broker) super().__init__(handler_type, handler_kwargs, exchange, routing_key, num_threads, broker)
if __name__ == '__main__': if __name__ == '__main__':
......
...@@ -72,8 +72,8 @@ def calculateCobaltSettings(spec): ...@@ -72,8 +72,8 @@ def calculateCobaltSettings(spec):
constraints = BlockConstraints(corr, coherent, incoherent, clock) constraints = BlockConstraints(corr, coherent, incoherent, clock)
calculator = BlockSize(constraints) calculator = BlockSize(constraints)
return {'nrSubblocks': calculator.nrSubblocks, 'blockSize': calculator.blockSize, return {'nrSubblocks': int(calculator.nrSubblocks), 'blockSize': int(calculator.blockSize),
'nrBlocks': calculator.nrBlocks, 'integrationTime': calculator.integrationTime} 'nrBlocks': int(calculator.nrBlocks), 'integrationTime': calculator.integrationTime}
def cobaltOTDBsettings(cobalt_values): def cobaltOTDBsettings(cobalt_values):
otdb_info = {} otdb_info = {}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment