Skip to content

Commit

Permalink
Fix bug
Browse files Browse the repository at this point in the history
Signed-off-by: Loic Pottier <pottier1@llnl.gov>
  • Loading branch information
lpottier authored and koparasy committed Aug 12, 2024
1 parent 6deecb0 commit 5dcbe64
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/AMSWorkflow/ams/orchestrator.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
"""
Expand Down

0 comments on commit 5dcbe64

Please sign in to comment.