autopep8 action fixes (#391)

Co-authored-by: mattldawson <mattldawson@users.noreply.github.com>
NCAR · May 15, 2024 · 9446b83 · 9446b83
1 parent 2f944f5
commit 9446b83
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 5 deletions.
diff --git a/interactive/rabbit_mq_model_runner.py b/interactive/rabbit_mq_model_runner.py
@@ -28,6 +28,8 @@
 logging.getLogger("pika").propagate = False
 
 # updates the status of the model run in the database
+
+
 def set_model_run_status(session_id, status, error=None, output=None):
     model_run = get_model_run(session_id)
     model_run.status = status
@@ -72,14 +74,18 @@ def music_box_exited_callback(session_id, output_directory):
         # read error file
         with open(error_path, "r") as f:
             set_model_run_status(
-                session_id, RunStatus.ERROR.value, error=f.read(), output=output_data
-            )
+                session_id,
+                RunStatus.ERROR.value,
+                error=f.read(),
+                output=output_data)
     elif os.path.exists(warning_path):
         # read warning file
         with open(warning_path, "r") as f:
             set_model_run_status(
-                session_id, RunStatus.ERROR.value, error=f.read(), output=output_data
-            )
+                session_id,
+                RunStatus.ERROR.value,
+                error=f.read(),
+                output=output_data)
     else:
         set_model_run_status(
             session_id,

diff --git a/interactive/shared/rabbit_mq.py b/interactive/shared/rabbit_mq.py
@@ -99,7 +99,8 @@ def consume(consumer_configs, rabbit_config=RabbitConfig()):
             for key in consumer.route_keys:
                 result = channel.queue_declare(queue=key)
                 queue_name = result.method.queue
-                logger.info(f"Binding {key} to {queue_name} on {rabbit_config.exchange}")
+                logger.info(
+                    f"Binding {key} to {queue_name} on {rabbit_config.exchange}")
                 channel.queue_bind(
                     exchange=rabbit_config.exchange,
                     queue=queue_name,