diff --git a/dap/worker.py b/dap/worker.py
index d79c8cb..4904952 100644
--- a/dap/worker.py
+++ b/dap/worker.py
@@ -49,7 +49,7 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host
         if not zmq_socks.has_data():
             continue
 
-        raw_data, metadata = zmq_socks.get_data()
+        raw_image, metadata = zmq_socks.get_data()
 
         if metadata["shape"] == [2, 2]: # this is used as marker for empty images
             continue
@@ -90,7 +90,7 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host
 
         double_pixels = results.get("double_pixels", "mask")
 
-        image = jfdata.process(raw_data, metadata, double_pixels)
+        image = jfdata.process(raw_image, metadata, double_pixels)
 
         if not image:
             continue
@@ -98,7 +98,7 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host
         pixel_mask_pf = jfdata.get_pixel_mask(results, double_pixels)
 
         if pixel_mask_pf is not None:
-            saturated_pixels_y, saturated_pixels_x = jfdata.get_saturated_pixels(raw_data, double_pixels)
+            saturated_pixels_y, saturated_pixels_x = jfdata.get_saturated_pixels(raw_image, double_pixels)
             results["saturated_pixels"] = len(saturated_pixels_x)
             results["saturated_pixels_x"] = saturated_pixels_x.tolist()
             results["saturated_pixels_y"] = saturated_pixels_y.tolist()