diff --git a/src/AMSWorkflow/ams/orchestrator.py b/src/AMSWorkflow/ams/orchestrator.py
index 17192167..c76fdc93 100644
--- a/src/AMSWorkflow/ams/orchestrator.py
+++ b/src/AMSWorkflow/ams/orchestrator.py
@@ -566,12 +566,12 @@ def __init__(
         self.json_file = json_file
 
     def __call__(self):
-        with self.producer as fd:
+        with self.producer as producer:
             with open(self.json_file, "r") as fd:
                 requests = json.load(fd)
                 for r in requests:
                     item = [r]
-                    fd.send_message(json.dumps(item))
+                    producer.send_message(json.dumps(item))
 
 class AMSRMQMessagePrinter(RMQLoaderTask):
     """