From 5dcbe640647db76519c97032cefb77ed92d91792 Mon Sep 17 00:00:00 2001 From: Loic Pottier Date: Fri, 9 Aug 2024 10:34:48 -0700 Subject: [PATCH] Fix bug Signed-off-by: Loic Pottier --- src/AMSWorkflow/ams/orchestrator.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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): """