try this

src/client/common/process/proc.ts

@@ -7,7 +7,8 @@ import { IDisposable } from '../types';
 import { EnvironmentVariables } from '../variables/types';
 import { execObservable, killPid, plainExec, shellExec } from './rawProcessApis';
 import { ExecutionResult, IProcessService, ObservableExecutionResult, ShellOptions, SpawnOptions } from './types';
-import { workerPlainExec, workerShellExec } from './worker/rawProcessApiWrapper';
+import { workerPlainExec } from './worker/workerPlainExec';
+import { workerShellExec } from './worker/workerShellExec';
 
 export class ProcessService extends EventEmitter implements IProcessService {
     private processesToKill = new Set<IDisposable>();

src/client/common/process/worker/plainExec.worker.ts → src/client/common/process/worker/workerPlainExec.ts

@@ -1,6 +1,25 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+import { SpawnOptions } from 'child_process';
 import { isMainThread, parentPort, workerData } from 'worker_threads';
+import { executeWorkerFile } from './main';
+import { ExecutionResult } from './types';
+
 import { _workerPlainExecImpl } from './workerRawProcessApis';
 
+export function workerPlainExec(
+    file: string,
+    args: string[],
+    options: SpawnOptions = {},
+): Promise<ExecutionResult<string>> {
+    return executeWorkerFile(__filename, {
+        file,
+        args,
+        options,
+    });
+}
+
 if (!isMainThread) {
     _workerPlainExecImpl(workerData.file, workerData.args, workerData.options)
         .then((res) => {

src/client/common/process/worker/shellExec.worker.ts → src/client/common/process/worker/workerShellExec.ts

@@ -1,6 +1,15 @@
 import { isMainThread, parentPort, workerData } from 'worker_threads';
+import { executeWorkerFile } from './main';
+import { ExecutionResult, ShellOptions } from './types';
 import { _workerShellExecImpl } from './workerRawProcessApis';
 
+export function workerShellExec(command: string, options: ShellOptions): Promise<ExecutionResult<string>> {
+    return executeWorkerFile(__filename, {
+        command,
+        options,
+    });
+}
+
 if (!isMainThread) {
     _workerShellExecImpl(workerData.command, workerData.options, workerData.defaultEnv)
         .then((res) => {