INNER CODE UNIT · Python

env

lij768423-svg/grok-register-panel · batch_supervisor.py:259

            env = {**os.environ, **dict(child_env or {})}
            env[PROGRESS_ENV] = str(progress_path)
            print(
                f"[supervisor] starting child remaining={remaining} workers={worker_count} restart={restarts}",
                flush=True,
            )
            active_process = subprocess.Popen(
                command,
                stdout=subprocess.PIPE,
                stderr=subprocess.STDOUT,
                text=False,
                bufsize=0,
                env=env,
                **popen_group_kwargs(),
            )
            assert active_process.stdout is not None
            output_queue: queue.Queue[bytes | None] = queue.Queue()
            reader = threading.Thread(

View source record →