we can reuse the experiment from above to avoid an API call

CHANGELOG.md

@@ -1,6 +1,12 @@
 ### Upcoming
  - Chart legend's will support more than 8 Pioreactors.
  - UI performance improvements.
+   - Upgraded to React 18
+   - Removed unused dependencies
+ - App performance improvements
+   - Upgrade paho-mqtt to 2.0
+   - faster `pio kill`
+   - faster startup from UI
 
 ### 24.5.1
 

pioreactor/background_jobs/base.py

@@ -338,14 +338,13 @@ def __post__init__(self) -> None:
         P.ready()
         C.on_ready()
         """
+        self.set_state(self.READY)
 
         with JobManager() as jm:
             self._jm_key = jm.register_and_set_running(
                 self.unit, self.experiment, self.job_name, self._job_source, getpid(), leader_hostname
             )
 
-        self.set_state(self.READY)
-
     def start_passive_listeners(self) -> None:
         # overwrite this to in subclasses to subscribe to topics in MQTT
         # using this handles reconnects correctly.

pioreactor/background_jobs/monitor.py

@@ -692,7 +692,9 @@ def run_job_on_machine(self, msg: MQTTMessage) -> None:
             self.logger.debug(f"Running `{job_name}` from monitor job.")
 
         else:
-            command = self._job_options_and_args_to_shell_command(job_name, args, options)
+            command = self._job_options_and_args_to_shell_command(
+                job_name, assigned_experiment, args, options
+            )
             Thread(
                 target=subprocess.run,
                 args=(command,),
@@ -703,10 +705,13 @@ def run_job_on_machine(self, msg: MQTTMessage) -> None:
 
     @staticmethod
     def _job_options_and_args_to_shell_command(
-        job_name: str, args: list[str], options: dict[str, Any]
+        job_name: str, experiment: str, args: list[str], options: dict[str, Any]
     ) -> str:
         core_command = ["pio", "run", job_name]
-        env = [f'JOB_SOURCE={options.pop("job_source", "user")}']
+
+        # job source could be experiment_profile, but defaults to user
+        # we actually can skip another API request by reusing the assigned experiment above...
+        env = [f'JOB_SOURCE={options.pop("job_source", "user")}', f"EXPERIMENT='{experiment}'"]
 
         list_of_options: list[str] = []
         for option, value in options.items():

pioreactor/whoami.py

@@ -40,7 +40,6 @@ def get_assigned_experiment_name(unit_name: str) -> str:
 
 def _get_assigned_experiment_name(unit_name: str) -> str:
     from pioreactor.logging import create_logger
-    from pioreactor import mureq
 
     if os.environ.get("EXPERIMENT") is not None:
         return os.environ["EXPERIMENT"]