diff --git a/sf_daq_broker/broker_manager.py b/sf_daq_broker/broker_manager.py index 3f4487e..89b65c5 100644 --- a/sf_daq_broker/broker_manager.py +++ b/sf_daq_broker/broker_manager.py @@ -82,7 +82,7 @@ def get_current_step_in_scan(meta_directory=None): return current_step -class BrokerManager(object): +class BrokerManager: REQUIRED_PARAMETERS = ["output_file"] def __init__(self, broker_client): diff --git a/sf_daq_broker/broker_manager_slow.py b/sf_daq_broker/broker_manager_slow.py index 087d76e..2b2f61f 100644 --- a/sf_daq_broker/broker_manager_slow.py +++ b/sf_daq_broker/broker_manager_slow.py @@ -63,7 +63,7 @@ def register_rest_interface(app, manager): return json.dumps({"state": "error", "status": error_text}) -class DetectorManager(object): +class DetectorManager: def get_detector_settings(self, request=None, remote_ip=None): diff --git a/sf_daq_broker/rabbitmq/msg_broker_client.py b/sf_daq_broker/rabbitmq/msg_broker_client.py index b5252e7..2bc9e7b 100644 --- a/sf_daq_broker/rabbitmq/msg_broker_client.py +++ b/sf_daq_broker/rabbitmq/msg_broker_client.py @@ -7,7 +7,7 @@ from pika import BlockingConnection, ConnectionParameters, BasicProperties from time import sleep -class RabbitMqClient(object): +class RabbitMqClient: def __init__(self, broker_url=broker_config.DEFAULT_BROKER_URL): self.broker_url = broker_url