class ProcessPythonEnvironmentManager implements PythonEnvironmentManager {

	@Override
	public RunnerApi.Environment createEnvironment() throws IOException, InterruptedException {
		Map<String, String> env = constructEnvironmentVariables();
		String pythonWorkerCommand = String.join(File.separator, baseDirectory, "pyflink-udf-runner.sh");

		return Environments.createProcessEnvironment(
			"",
			"",
			pythonWorkerCommand,
			env);
	}

	public  ProcessPythonEnvironmentManager(
		@NotNull PythonDependencyInfo dependencyInfo,
		@NotNull String[] tmpDirectories,
		@NotNull Map<String, String> systemEnv);

}