SourceFunctions are run in the Scheduler process so does not have its…

… own set of environmental config variables (getenv(), $_ENV) like source processes do. We instead set a protected class variable $env that the SourceFunction can use.

src/Scheduler.php

@@ -315,6 +315,7 @@ public function setup_source_function(int|string $id): void
     {
         $config = $this->input_processes_config[$id];
         $cmd = clone $config['cmd'];
+        $env = $config['env'];
 
         $this->input_processes[$id] = $cmd;
         /** Log any errors received. Wrapper will call exit after error */
@@ -342,8 +343,8 @@ public function setup_source_function(int|string $id): void
                 $this->shutdown();
             }
         });
-        $this->loop->futureTick(static function() use ($cmd) {
-            $cmd->start();
+        $this->loop->futureTick(static function() use ($cmd, $env) {
+            $cmd->start($env);
         });
     }
 

src/Scheduler/SourceFunction.php

@@ -28,13 +28,20 @@ abstract class SourceFunction implements LoggerAwareInterface, EventEmitterInter
     protected bool $running = false;
     protected LoopInterface $loop;
 
+    /** @var array The environment for this source function */
+    protected array $env;
+
     public function __construct() {
         $this->loop = Loop::get();
     }
 
-    public function start(): void
+    /**
+     * @var null|array $env Set the environment for the source function or inherit if null
+     */
+    public function start(null|array $env = null): void
     {
         $this->running = true;
+        $this->env = $env ?? getenv();
         $this->functionStart();
     }