Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
GDYendell committed Jul 31, 2024
1 parent 53be11e commit dad9834
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion python/src/odin_data/control/frame_processor_controller.py
Original file line number Diff line number Diff line change
Expand Up @@ -74,6 +74,7 @@ def execute_write(self, value):
# Queue the write command
logging.error("Writing command: {}".format(value))

processes = self._odin_adapter_fps._controller.get("count", False)["count"]
if value:
# Before attempting to write files, make some simple error checks

Expand All @@ -91,7 +92,6 @@ def execute_write(self, value):
# First setup the rank for the frameProcessor applications
self.setup_rank()

processes = self._odin_adapter_fps._controller.get("count", False)["count"]
try:
for rank in range(processes):
# Setup the number of processes and the rank for each client
Expand All @@ -117,6 +117,7 @@ def execute_write(self, value):
except Exception as err:
logging.debug("Failed to send rank information to FP applications")
logging.error("Error: %s", err)

try:
config = {'hdf': {'write': value}}
for rank in range(processes):
Expand Down

0 comments on commit dad9834

Please sign in to comment.