Aviary command line refactor

.gitignore

@@ -135,7 +135,6 @@ reports/
 aviary/reports/
 *.openmdao_out
 *.out
-*.png
 *.sql
 *.db
 *.pdf

aviary/core/aviary_problem.py

@@ -1,20 +1,23 @@
 import csv
 import json
 import os
+import subprocess
 import warnings
 from copy import deepcopy
 from datetime import datetime
 from enum import Enum
 from pathlib import Path
+from packaging import version
+
+import numpy as np
 from itertools import count
 
 import dymos as dm
-import numpy as np
 import openmdao
 import openmdao.api as om
 from openmdao.utils.reports_system import _default_reports
 from openmdao.utils.units import convert_units
-from packaging import version
+import openmdao.utils.hooks as hooks
 
 from aviary.core.aviary_group import AviaryGroup
 from aviary.interface.utils import set_warning_format
@@ -1176,6 +1179,7 @@ def run_aviary_problem(
         simulate=False,
         make_plots=True,
         verbosity=None,
+        rt=False,
     ):
         """
         This function actually runs the Aviary problem, which could be a simulation,
@@ -1211,13 +1215,44 @@ def run_aviary_problem(
         else:
             verbosity = self.verbosity  # defaults to BRIEF
 
-        if verbosity >= Verbosity.VERBOSE:  # VERBOSE, DEBUG
+        if (
+            verbosity >= Verbosity.VERBOSE or rt
+        ):  # rt needs a driver recorder file to run the realtime plot server
+            recorder = om.SqliteRecorder('optimization_history.db')
+            self.driver.add_recorder(recorder)
             self.final_setup()
+
+        if verbosity >= Verbosity.VERBOSE:  # VERBOSE, DEBUG
             with open(self.get_reports_dir() / 'input_list.txt', 'w') as outfile:
                 self.model.list_inputs(out_stream=outfile)
 
-            recorder = om.SqliteRecorder('optimization_history.db')
-            self.driver.add_recorder(recorder)
+        def _view_realtime_plot_hook(driver):
+            case_recorder_file = str(driver._rec_mgr._recorders[0]._filepath)
+
+            cmd = ['openmdao', 'realtime_plot', '--pid', str(os.getpid()), case_recorder_file]
+            cp = subprocess.Popen(cmd)  # nosec: trusted input
+
+            # Do a quick non-blocking check to see if it immediately failed
+            # This will catch immediate failures but won't wait for the process to finish
+            quick_check = cp.poll()
+            if quick_check is not None and quick_check != 0:
+                # Process already terminated with an error
+                stderr = cp.stderr.read().decode()
+                raise RuntimeError(
+                    f'Failed to start up the realtime plot server with code {quick_check}: {stderr}.'
+                )
+
+        # register the hook to stat up the real-time plot server
+        if rt:
+            if not self.driver:
+                raise RuntimeError(
+                    'Unable to run realtime optimization progress plot because no Driver'
+                )
+
+            hooks._register_hook(
+                '_setup_recording', 'Driver', post=_view_realtime_plot_hook, ncalls=1
+            )
+            hooks._setup_hooks(self.driver)
 
         if suppress_solver_print:
             self.set_solver_print(level=0)

aviary/docs/examples_unreviewed/deconstructed_example.ipynb

@@ -889,7 +889,7 @@
    "outputs": [],
    "source": [
     "# Testing Cell\n",
-    "from aviary.interface.download_models import get_model\n",
+    "from aviary.utils.functions import get_model\n",
     "\n",
     "get_model('advanced_single_aisle/advanced_single_aisle_data.py')"
    ]
@@ -937,7 +937,7 @@
     "# Testing Cell\n",
     "import os\n",
     "\n",
-    "from aviary.interface.download_models import get_model\n",
+    "from aviary.utils.functions import get_model\n",
     "\n",
     "all_files = {\n",
     "    'large_single_aisle_1': [''],\n",