marked unused arguments

sf_daq_broker/rabbitmq/broker_debugger.py

@@ -19,7 +19,7 @@ def get_color_for_action(action):
     return color_mapping.get(action, "")
 
 
-def on_status(channel, method_frame, header_frame, body):
+def on_status(_channel, _method_frame, header_frame, body):
     header = header_frame.headers
     request = json.loads(body.decode())
 

sf_daq_broker/writer/bsread_writer.py

@@ -78,7 +78,7 @@ def check_data_consistency(start_pulse_id, stop_pulse_id, rate_multiplicator, ch
     _logger.info(f"Check of data consistency took {time_delta} seconds.")
 
 
-def write_from_imagebuffer(data_api_request, output_file, parameters):
+def write_from_imagebuffer(data_api_request, output_file, _parameters):
     import data_api3.h5 as h5
 
     start_pulse_id = data_api_request["range"]["startPulseId"]
@@ -124,7 +124,7 @@ def write_from_imagebuffer(data_api_request, output_file, parameters):
 
     check_data_consistency(start_pulse_id, stop_pulse_id, rate_multiplicator, channels, output_file)
 
-def write_from_databuffer_api3(data_api_request, output_file, parameters):
+def write_from_databuffer_api3(data_api_request, output_file, _parameters):
     import data_api3.h5 as h5
 
     _logger.debug(f"Data3 API request: {data_api_request}")

sf_daq_broker/writer/detector_writer.py

@@ -125,7 +125,7 @@ def detector_retrieve(request, output_file_detector):
 
 
 
-def create_pedestal_file(filename="pedestal.h5", X_test_pixel=0, Y_test_pixel=0, nFramesPede=1000,
+def create_pedestal_file(filename="pedestal.h5", X_test_pixel=0, Y_test_pixel=0, _nFramesPede=1000, #TODO: what is nFramesPede for?
                          number_frames=10000, frames_average=1000,
                          directory="./", gain_check=1, add_pixel_mask=None, number_bad_modules=0):
 

sf_daq_broker/writer/epics_writer.py

@@ -21,7 +21,7 @@ def verify_data(pv_list, processed_data):
             _logger.error(f"PV {pv} not present.")
 
 
-def write_epics_pvs(output_file, start_pulse_id, stop_pulse_id, metadata, epics_pvs):
+def write_epics_pvs(output_file, start_pulse_id, stop_pulse_id, _metadata, epics_pvs): #TODO: what is _metadata for?
     _logger.info(f"Writing {output_file} from start_pulse_id {start_pulse_id} to stop_pulse_id {stop_pulse_id}.")
     _logger.debug(f"Requesting PVs: {epics_pvs}")
 

sf_daq_broker/writer/start.py

@@ -229,7 +229,7 @@ def reject_request(channel, method_frame, body, output_file, e):
     update_status(channel, body, "write_rejected", output_file, str(e))
 
 
-def on_broker_message(channel, method_frame, header_frame, body, connection, broker_client):
+def on_broker_message(channel, method_frame, _header_frame, body, connection, broker_client):
 
     try:
         request = json.loads(body.decode())