diff --git a/ProcessMaker/Enums/ScriptExecutorType.php b/ProcessMaker/Enums/ScriptExecutorType.php
index c4e7774c90..9a217ea478 100644
--- a/ProcessMaker/Enums/ScriptExecutorType.php
+++ b/ProcessMaker/Enums/ScriptExecutorType.php
@@ -7,4 +7,10 @@ enum ScriptExecutorType:string
     case System = 'system';
     case Custom = 'custom';
     case Duplicate = 'duplicate';
+    case Realtime = 'realtime';
+
+    public function isCustomOrRealtime(): bool
+    {
+        return $this === self::Custom || $this === self::Realtime;
+    }
 }
diff --git a/ProcessMaker/Events/ScriptResponseEvent.php b/ProcessMaker/Events/ScriptResponseEvent.php
index f44e8fc40a..2837e11594 100644
--- a/ProcessMaker/Events/ScriptResponseEvent.php
+++ b/ProcessMaker/Events/ScriptResponseEvent.php
@@ -25,18 +25,21 @@ class ScriptResponseEvent implements ShouldBroadcastNow
 
     public $nonce;
 
+    public $duration;
+
     /**
      * Create a new event instance.
      *
      * @return void
      */
-    public function __construct(User $user, $status, array $response, $watcher = null, $nonce = null)
+    public function __construct(User $user, $status, array $response, $watcher = null, $nonce = null, $duration = null)
     {
         $this->userId = $user->id;
         $this->status = $status;
         $this->response = $response;
         $this->watcher = $watcher;
         $this->nonce = $nonce;
+        $this->duration = $duration;
     }
 
     /**
@@ -75,6 +78,7 @@ public function broadcastWith()
             'watcher' => $this->watcher,
             'response' => $response,
             'nonce' => $this->nonce,
+            'duration' => $this->duration,
         ];
     }
 }
diff --git a/ProcessMaker/Http/Controllers/Admin/ScriptExecutorController.php b/ProcessMaker/Http/Controllers/Admin/ScriptExecutorController.php
index 230458ad89..5dfe1df1fd 100644
--- a/ProcessMaker/Http/Controllers/Admin/ScriptExecutorController.php
+++ b/ProcessMaker/Http/Controllers/Admin/ScriptExecutorController.php
@@ -8,15 +8,20 @@
 
 class ScriptExecutorController extends Controller
 {
-    public function index(Request $request)
+    public function index(Request $request, ScriptMicroserviceService $service)
     {
         if (!config('app.custom_executors')) {
             abort(404);
         }
 
+        $scriptMicroserviceEnabled = config('script-runner-microservice.enabled');
+
         return view('admin.script-executors.index',
             [
-                'script_microservice_enabled' => config('script-runner-microservice.enabled'),
+                'script_microservice_enabled' => $scriptMicroserviceEnabled,
+                'script_microservice_tenant_id' => $scriptMicroserviceEnabled
+                    ? $service->getInstanceUuid()
+                    : null,
             ]);
     }
 }
diff --git a/ProcessMaker/Http/Controllers/Api/ScriptController.php b/ProcessMaker/Http/Controllers/Api/ScriptController.php
index e3cca93814..80d1e3b78e 100644
--- a/ProcessMaker/Http/Controllers/Api/ScriptController.php
+++ b/ProcessMaker/Http/Controllers/Api/ScriptController.php
@@ -4,6 +4,7 @@
 
 use Illuminate\Http\Request;
 use Illuminate\Support\Facades\Cache;
+use ProcessMaker\Enums\ScriptExecutorType;
 use ProcessMaker\Events\ScriptCreated;
 use ProcessMaker\Events\ScriptDeleted;
 use ProcessMaker\Events\ScriptDuplicated;
@@ -178,7 +179,7 @@ public function index(Request $request)
      *
      *     @OA\Response(
      *         response=200,
-     *         description="success if the script was queued",
+     *         description="The queued status or realtime execution response",
      *         ),
      *     ),
      * )
@@ -190,7 +191,12 @@ public function preview(Request $request, Script $script)
         $code = $request->get('code');
         $nonce = $request->get('nonce');
 
-        TestScript::dispatch($script, $request->user(), $code, $data, $config, $nonce)->onQueue('bpmn');
+        $job = TestScript::dispatch($script, $request->user(), $code, $data, $config, $nonce);
+        if ($script->scriptExecutor->type === ScriptExecutorType::Realtime) {
+            $job->onConnection('redis-realtime')->onQueue('realtime');
+        } else {
+            $job->onQueue('bpmn');
+        }
 
         return ['status' => 'success'];
     }
@@ -249,7 +255,12 @@ public function execute(Request $request, ...$scriptKey)
         if ($request->get('sync') === true) {
             return (new ExecuteScript($script, $request->user(), $code, $data, $watcher, $config, true))->handle();
         } else {
-            ExecuteScript::dispatch($script, $request->user(), $code, $data, $watcher, $config)->onQueue('bpmn');
+            $job = ExecuteScript::dispatch($script, $request->user(), $code, $data, $watcher, $config);
+            if ($script->scriptExecutor->type === ScriptExecutorType::Realtime) {
+                $job->onConnection('redis-realtime')->onQueue('realtime');
+            } else {
+                $job->onQueue('bpmn');
+            }
         }
 
         return ['status' => 'success', 'key' => $watcher];
diff --git a/ProcessMaker/Http/Controllers/Api/ScriptExecutorController.php b/ProcessMaker/Http/Controllers/Api/ScriptExecutorController.php
index 7627c9d7a4..80bc624891 100644
--- a/ProcessMaker/Http/Controllers/Api/ScriptExecutorController.php
+++ b/ProcessMaker/Http/Controllers/Api/ScriptExecutorController.php
@@ -4,6 +4,7 @@
 
 use Illuminate\Auth\Access\AuthorizationException;
 use Illuminate\Database\Eloquent\ModelNotFoundException;
+use Illuminate\Http\Client\RequestException;
 use Illuminate\Http\Request;
 use Illuminate\Validation\ValidationException;
 use ProcessMaker\Enums\ScriptExecutorType;
@@ -124,7 +125,15 @@ public function store(Request $request, ScriptMicroserviceService $service)
             ScriptExecutorCreated::dispatch($scriptExecutor->getAttributes());
             BuildScriptExecutor::dispatch($scriptExecutor->id, $request->user()->id);
         } else {
-            $service->createCustomExecutor($scriptExecutor);
+            try {
+                $service->createCustomExecutor($scriptExecutor);
+            } catch (RequestException $e) {
+                // The remote executor was rejected, so keeping the local record would leave
+                // an executor that can never be built.
+                $scriptExecutor->delete();
+
+                $this->throwMicroserviceError($e);
+            }
         }
 
         return ['status' => 'started', 'uuid' => $scriptExecutor->uuid, 'id' => $scriptExecutor->id];
@@ -188,8 +197,12 @@ public function update(Request $request, ScriptExecutor $scriptExecutor, ScriptM
             $request->only($scriptExecutor->getFillable())
         );
 
-        if (config('script-runner-microservice.enabled') && $scriptExecutor->type == ScriptExecutorType::Custom) {
-            $service->updateCustomExecutor($scriptExecutor);
+        if (config('script-runner-microservice.enabled') && $scriptExecutor->type?->isCustomOrRealtime()) {
+            try {
+                $service->updateCustomExecutor($scriptExecutor);
+            } catch (RequestException $e) {
+                $this->throwMicroserviceError($e);
+            }
         } else {
             if (!empty($scriptExecutor->getChanges())) {
                 ScriptExecutorUpdated::dispatch($scriptExecutor->id, $original, $scriptExecutor->getChanges());
@@ -274,6 +287,28 @@ public function delete(Request $request, ScriptExecutor $scriptExecutor, ScriptM
         return ['status' => 'done'];
     }
 
+    /**
+     * Report a script microservice rejection on the form, since the build itself
+     * is only reported over the websocket channel.
+     *
+     * @param RequestException $e Failed script microservice response
+     *
+     * @return never
+     *
+     * @throws ValidationException|RequestException
+     */
+    private function throwMicroserviceError(RequestException $e): never
+    {
+        if (!$e->response->clientError()) {
+            throw $e;
+        }
+
+        $detail = $e->response->json('detail');
+        $message = is_string($detail) && $detail !== '' ? $detail : $e->getMessage();
+
+        throw ValidationException::withMessages(['language' => [$message]]);
+    }
+
     private function checkAuth($request)
     {
         if (!config('app.custom_executors')) {
@@ -381,11 +416,30 @@ public function availableLanguages()
                 $languages[] = [
                     'value' => $key,
                     'text' => $config['name'],
+                    'language' => $key,
+                    'realtime' => false,
                     'initDockerfile' => ScriptExecutor::initDockerfile($key),
+                    'configExample' => '',
                 ];
             }
         }
 
+        foreach (['php', 'python', 'javascript'] as $language) {
+            $dockerfilePath = resource_path("script-executors/realtime/{$language}.Dockerfile");
+            if (!file_exists($dockerfilePath)) {
+                continue;
+            }
+            $label = $language === 'javascript' ? 'nodejs (realtime)' : "{$language} (realtime)";
+            $languages[] = [
+                'value' => "{$language}-realtime",
+                'text' => $label,
+                'language' => $language,
+                'realtime' => true,
+                'initDockerfile' => '',
+                'configExample' => file_get_contents($dockerfilePath),
+            ];
+        }
+
         return ['languages' => $languages];
     }
 }
diff --git a/ProcessMaker/Jobs/ErrorHandling.php b/ProcessMaker/Jobs/ErrorHandling.php
index 63c3161040..b6cddf2680 100644
--- a/ProcessMaker/Jobs/ErrorHandling.php
+++ b/ProcessMaker/Jobs/ErrorHandling.php
@@ -83,7 +83,8 @@ private function requeue($job)
             );
         }
         $newJob->delay($this->retryWaitTime());
-        $newJob->onQueue('bpmn');
+        $newJob->onConnection($job->connection);
+        $newJob->onQueue($job->queue ?? 'bpmn');
         dispatch($newJob);
     }
 
diff --git a/ProcessMaker/Jobs/TestScript.php b/ProcessMaker/Jobs/TestScript.php
index 4a5050d2d0..a152c9bab0 100644
--- a/ProcessMaker/Jobs/TestScript.php
+++ b/ProcessMaker/Jobs/TestScript.php
@@ -7,10 +7,12 @@
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\Log;
 use ProcessMaker\Enums\ScriptExecutorType;
 use ProcessMaker\Events\ScriptResponseEvent;
 use ProcessMaker\Models\Script;
 use ProcessMaker\Models\User;
+use ProcessMaker\Services\ScriptMicroserviceService;
 use Throwable;
 
 class TestScript implements ShouldQueue
@@ -35,8 +37,8 @@ class TestScript implements ShouldQueue
     /**
      * Create a new job instance to execute a script.
      *
-     * @param ProcessMaker\Models\Script $script
-     * @param ProcessMaker\Models\User $current_user
+     * @param Script $script
+     * @param User $current_user
      * @param string $code
      * @param array $data
      * @param array $configuration
@@ -58,24 +60,31 @@ public function __construct(Script $script, User $current_user, $code, array $da
      */
     public function handle()
     {
+        $startTime = microtime(true);
         try {
             // Just set the code but do not save the object (preview only)
             $this->script->code = $this->code;
             $metadata = [
                 'nonce' => $this->nonce,
                 'current_user' => $this->current_user?->id,
+                'start_time' => microtime(true),
             ];
             $response = $this->script->runScript($this->data, $this->configuration, '', null, 0, $metadata);
-            \Log::debug('Response from runScript: ' . print_r($response, true));
+            Log::debug('Response from runScript: ' . print_r($response, true));
 
-            if (!config('script-runner-microservice.enabled')) {
-                $this->sendResponse(200, $response);
+            if ($this->script->scriptExecutor->type === ScriptExecutorType::Realtime) {
+                // Realtime executors return the microservice payload synchronously rather than
+                // posting back to the callback endpoint, so format it the same way here.
+                $formatted = (new ScriptMicroserviceService())->formatPreviewResponse($response);
+                $this->sendResponse($formatted['status'], $formatted['output'], (microtime(true) - $startTime));
+            } elseif (!config('script-runner-microservice.enabled')) {
+                $this->sendResponse(200, $response, (microtime(true) - $startTime));
             }
         } catch (Throwable $exception) {
             $this->sendResponse(500, [
                 'exception' => get_class($exception),
                 'message' => $exception->getMessage(),
-            ]);
+            ], (microtime(true) - $startTime));
         }
     }
 
@@ -85,8 +94,8 @@ public function handle()
      * @param int $status
      * @param array $response
      */
-    private function sendResponse($status, array $response)
+    private function sendResponse($status, array $response, float $duration)
     {
-        event(new ScriptResponseEvent($this->current_user, $status, $response, null, $this->nonce));
+        event(new ScriptResponseEvent($this->current_user, $status, $response, null, $this->nonce, $duration));
     }
 }
diff --git a/ProcessMaker/Models/Script.php b/ProcessMaker/Models/Script.php
index f01c7f4492..3853001bfd 100644
--- a/ProcessMaker/Models/Script.php
+++ b/ProcessMaker/Models/Script.php
@@ -179,6 +179,7 @@ public function runScript(array $data, array $config, $tokenId = '', $timeout =
         if (!$user) {
             throw new ConfigurationException('A user is required to run scripts');
         }
+        $metadata['start_time'] = microtime(true);
 
         return $runner->run($this->code, $data, $config, $timeout, $user, $sync, $metadata);
     }
diff --git a/ProcessMaker/Models/ScriptExecutor.php b/ProcessMaker/Models/ScriptExecutor.php
index 6e5438f279..408b9e457d 100644
--- a/ProcessMaker/Models/ScriptExecutor.php
+++ b/ProcessMaker/Models/ScriptExecutor.php
@@ -32,6 +32,7 @@
  *   @OA\Property(property="language", type="string"),
  *   @OA\Property(property="config", type="string"),
  *   @OA\Property(property="is_system", type="boolean"),
+ *   @OA\Property(property="type", type="string"),
  * ),
  * @OA\Schema(
  *   schema="scriptExecutors",
@@ -177,6 +178,12 @@ public static function rules($existing = null)
             });
         }
 
+        // Realtime executors may use php/python/javascript even if a package is not installed
+        $allowedLanguages = array_values(array_unique(array_merge(
+            $allowedLanguages,
+            ['php', 'python', 'javascript']
+        )));
+
         return [
             'title' => 'required',
             'language' => [
diff --git a/ProcessMaker/Nayra/Managers/WorkflowManagerDefault.php b/ProcessMaker/Nayra/Managers/WorkflowManagerDefault.php
index 11a8d3007f..cb521091a7 100644
--- a/ProcessMaker/Nayra/Managers/WorkflowManagerDefault.php
+++ b/ProcessMaker/Nayra/Managers/WorkflowManagerDefault.php
@@ -8,6 +8,7 @@
 use ProcessMaker\BpmnEngine;
 use ProcessMaker\Contracts\ServiceTaskImplementationInterface;
 use ProcessMaker\Contracts\WorkflowManagerInterface;
+use ProcessMaker\Enums\ScriptExecutorType;
 use ProcessMaker\Jobs\BoundaryEvent;
 use ProcessMaker\Jobs\CallProcess;
 use ProcessMaker\Jobs\CatchEvent;
@@ -23,6 +24,7 @@
 use ProcessMaker\Models\Process as Definitions;
 use ProcessMaker\Models\ProcessRequest;
 use ProcessMaker\Models\ProcessRequestToken as Token;
+use ProcessMaker\Models\Script;
 use ProcessMaker\Nayra\Contracts\Bpmn\BoundaryEventInterface;
 use ProcessMaker\Nayra\Contracts\Bpmn\EntityInterface;
 use ProcessMaker\Nayra\Contracts\Bpmn\EventDefinitionInterface;
@@ -231,7 +233,14 @@ public function runScripTask(ScriptTaskInterface $scriptTask, Token $token)
 
         $instance = $token->processRequest;
         $process = $instance->process;
-        RunScriptTask::dispatch($process, $instance, $token, [])->onQueue('bpmn');
+        $job = new RunScriptTask($process, $instance, $token, []);
+        $script = Script::find($scriptTask->getProperty('scriptRef'));
+
+        if ($script?->scriptExecutor?->type === ScriptExecutorType::Realtime) {
+            $job->onConnection('redis-realtime')->onQueue('realtime');
+        }
+
+        dispatch($job);
     }
 
     /**
diff --git a/ProcessMaker/ScriptRunners/ScriptMicroserviceRunner.php b/ProcessMaker/ScriptRunners/ScriptMicroserviceRunner.php
index dc4d5f3a96..a4c603d117 100644
--- a/ProcessMaker/ScriptRunners/ScriptMicroserviceRunner.php
+++ b/ProcessMaker/ScriptRunners/ScriptMicroserviceRunner.php
@@ -40,7 +40,7 @@ public function run($code, array $data, array $config, $timeout, $user, $sync, $
         $scriptRunner = $this->service->getScriptRunner(
             $this->language,
             $this->script->scriptExecutor->uuid,
-            $this->script->scriptExecutor->type === ScriptExecutorType::Custom
+            $this->script->scriptExecutor->type?->isCustomOrRealtime()
         );
 
         if (!$scriptRunner) {
@@ -62,7 +62,8 @@ public function run($code, array $data, array $config, $timeout, $user, $sync, $
             'callback_token' => $environmentVariables['API_TOKEN'],
             'debug' => true,
             'timeout' => $timeout,
-            'sync' => $sync,
+            // Realtime executors always run synchronously (service ignores sync too)
+            'sync' => $this->script->scriptExecutor->type === ScriptExecutorType::Realtime ? true : $sync,
         ];
 
         Log::debug('Payload: ' . print_r($payload, true));
diff --git a/ProcessMaker/Services/ScriptMicroserviceService.php b/ProcessMaker/Services/ScriptMicroserviceService.php
index b3a8a114ce..61098bcaee 100644
--- a/ProcessMaker/Services/ScriptMicroserviceService.php
+++ b/ProcessMaker/Services/ScriptMicroserviceService.php
@@ -9,6 +9,7 @@
 use Illuminate\Support\Facades\Cache;
 use Illuminate\Support\Facades\Http;
 use Illuminate\Support\Facades\Log;
+use ProcessMaker\Enums\ScriptExecutorType;
 use ProcessMaker\Events\ScriptResponseEvent;
 use ProcessMaker\Exception\ScriptException;
 use ProcessMaker\Jobs\CompleteActivity;
@@ -87,6 +88,7 @@ public function createCustomExecutor(ScriptExecutor $scriptExecutor)
             'language' => strtolower($scriptExecutor->language),
             'version' => config('script-runner-microservice.version'),
             'config' => $scriptExecutor->config,
+            'realtime' => $scriptExecutor->type === ScriptExecutorType::Realtime,
         ];
         Log::debug('Payload: ', $payload);
 
@@ -114,6 +116,7 @@ public function updateCustomExecutor(ScriptExecutor $scriptExecutor)
             'language' => strtolower($scriptExecutor->language),
             'version' => config('script-runner-microservice.version'),
             'config' => $scriptExecutor->config,
+            'realtime' => $scriptExecutor->type === ScriptExecutorType::Realtime,
         ];
         Log::debug('Payload: ', $payload);
 
@@ -195,6 +198,7 @@ public function getScriptRunner(string $language, string $executorUuid, bool $cu
 
         if (Cache::has($cacheKey)) {
             Log::debug('Cache hit for script runner', ['cacheKey' => $cacheKey]);
+
             return Cache::get($cacheKey);
         }
 
@@ -211,7 +215,9 @@ public function getScriptRunner(string $language, string $executorUuid, bool $cu
                 return isset($item['language'], $item['id']) && $item['language'] === $language && $item['id'] === $executorUuid;
             })->first();
 
-        if (!empty($result)) Cache::put($cacheKey, $result, now()->addHour());
+        if (!empty($result)) {
+            Cache::put($cacheKey, $result, now()->addHour());
+        }
 
         return $result;
     }
@@ -235,6 +241,9 @@ public function handle(Request $request): void
     {
         $response = $request->all();
         Log::debug('Response microservice executor: ' . print_r($response, true));
+
+        $duration = isset($response['metadata']['start_time']) ? (microtime(true) - $response['metadata']['start_time']) : null;
+
         // If the call is from preview
         if (!empty($response['metadata']['nonce'])) {
             $formattedResponse = $this->formatPreviewResponse($response);
@@ -243,7 +252,8 @@ public function handle(Request $request): void
                 $formattedResponse['status'],
                 $formattedResponse['output'],
                 null,
-                $response['metadata']['nonce']));
+                $response['metadata']['nonce'],
+                $duration));
         }
         if (!empty($response['metadata']['script_task'])) {
             $script = Script::find($response['metadata']['script_task']['script_id']);
@@ -262,10 +272,10 @@ public function handle(Request $request): void
      * @param array $response
      * @return array{status: int, output: array}
      */
-    private function formatPreviewResponse(array $response): array
+    public function formatPreviewResponse(array $response): array
     {
         // Simple status determination: success = 200, others = 500
-        $status = $response['status'] === 'success' ? 200 : 500;
+        $status = ($response['status'] ?? '') === 'success' ? 200 : 500;
 
         return [
             'status' => $status,
@@ -284,7 +294,7 @@ private function formatPreviewOutput(array $response): array
         $output = $response;
         if (($response['status'] ?? '') === 'success') {
             $output = ['output' => $response['output']];
-        } elseif ($response['status'] === 'error') {
+        } elseif (($response['status'] ?? '') === 'error') {
             $output = [
                 'exception' => $response['exception'] ?? ScriptException::class,
                 'message' => $response['error'],
diff --git a/config/horizon.php b/config/horizon.php
index af57f786e1..4569dad6de 100644
--- a/config/horizon.php
+++ b/config/horizon.php
@@ -163,6 +163,16 @@
                 'maxProcesses' => env('PM4_HORIZON_SUPERVISOR_1_MAX_PROCESSES', 1),
                 'memory' => env('PM4_HORIZON_WORKER_MEMORY_LIMIT', 512),
             ],
+            'supervisor-realtime' => [
+                'connection' => 'redis-realtime',
+                'queue' => ['realtime'],
+                'balance' => env('PM4_HORIZON_SUPERVISOR_REALTIME_BALANCE', 'auto'), // auto: dynamically adjust the number of processes based on the load
+                'tries' => env('PM4_HORIZON_SUPERVISOR_REALTIME_TRIES', 3),
+                'timeout' => env('PM4_HORIZON_SUPERVISOR_REALTIME_TIMEOUT', 600),
+                'minProcesses' => env('PM4_HORIZON_SUPERVISOR_REALTIME_MIN_PROCESSES', 2),
+                'maxProcesses' => env('PM4_HORIZON_SUPERVISOR_REALTIME_MAX_PROCESSES', 20),
+                'memory' => env('PM4_HORIZON_WORKER_MEMORY_LIMIT', 512),
+            ],
         ],
 
         'local' => [
@@ -187,6 +197,16 @@
                 'maxProcesses' => env('PM4_HORIZON_SUPERVISOR_1_MAX_PROCESSES', 1),
                 'memory' => env('PM4_HORIZON_WORKER_MEMORY_LIMIT', 512),
             ],
+            'supervisor-realtime' => [
+                'connection' => 'redis-realtime',
+                'queue' => ['realtime'],
+                'balance' => env('PM4_HORIZON_SUPERVISOR_REALTIME_BALANCE', 'auto'), // auto: dynamically adjust the number of processes based on the load
+                'tries' => env('PM4_HORIZON_SUPERVISOR_REALTIME_TRIES', 3),
+                'timeout' => env('PM4_HORIZON_SUPERVISOR_REALTIME_TIMEOUT', 600),
+                'minProcesses' => env('PM4_HORIZON_SUPERVISOR_REALTIME_MIN_PROCESSES', 2),
+                'maxProcesses' => env('PM4_HORIZON_SUPERVISOR_REALTIME_MAX_PROCESSES', 20),
+                'memory' => env('PM4_HORIZON_WORKER_MEMORY_LIMIT', 512),
+            ],
         ],
 
         'staging' => [
@@ -211,6 +231,16 @@
                 'maxProcesses' => env('PM4_HORIZON_SUPERVISOR_1_MAX_PROCESSES', 1),
                 'memory' => env('PM4_HORIZON_WORKER_MEMORY_LIMIT', 512),
             ],
+            'supervisor-realtime' => [
+                'connection' => 'redis-realtime',
+                'queue' => ['realtime'],
+                'balance' => env('PM4_HORIZON_SUPERVISOR_REALTIME_BALANCE', 'auto'),
+                'tries' => env('PM4_HORIZON_SUPERVISOR_REALTIME_TRIES', 3),
+                'timeout' => env('PM4_HORIZON_SUPERVISOR_REALTIME_TIMEOUT', 600),
+                'minProcesses' => env('PM4_HORIZON_SUPERVISOR_REALTIME_MIN_PROCESSES', 2),
+                'maxProcesses' => env('PM4_HORIZON_SUPERVISOR_REALTIME_MAX_PROCESSES', 20),
+                'memory' => env('PM4_HORIZON_WORKER_MEMORY_LIMIT', 512),
+            ],
         ],
     ],
 ];
diff --git a/config/queue.php b/config/queue.php
index c5029a5baa..6bda789295 100644
--- a/config/queue.php
+++ b/config/queue.php
@@ -71,6 +71,15 @@
             'after_commit' => false,
         ],
 
+        'redis-realtime' => [
+            'driver' => 'redis',
+            'connection' => 'default',
+            'queue' => 'realtime',
+            'retry_after' => 86400,
+            'block_for' => 10,
+            'after_commit' => false,
+        ],
+
     ],
 
     /*
diff --git a/resources/js/admin/script-executors/ScriptExecutors.vue b/resources/js/admin/script-executors/ScriptExecutors.vue
index 63970dc86c..1de44521cb 100644
--- a/resources/js/admin/script-executors/ScriptExecutors.vue
+++ b/resources/js/admin/script-executors/ScriptExecutors.vue
@@ -32,7 +32,7 @@
           <span v-uni-id="props.rowData.id.toString()">{{ props.rowData.title }}</span>
         </template>
         <template slot="type" slot-scope="props">
-          {{ (props.rowData.type === "custom") ? "Custom" : "Base" }}
+          {{ typeLabel(props.rowData.type) }}
         </template>
 
         <template slot="actions" slot-scope="props">
@@ -49,7 +49,7 @@
               </b-btn>
               <b-btn
                 variant="link"
-                :disabled="props.rowData.type !== 'custom'"
+                :disabled="!isEditableType(props.rowData.type)"
                 @click="deleteExecutor(props.rowData)"
                 v-b-tooltip.hover
                 :title="$t('Delete')"
@@ -110,7 +110,7 @@
                   required
                   v-model="formData.title"
                   name="title"
-                  :disabled="formData.type !== 'custom'"
+                  :disabled="!isEditableType(formData.type)"
                 ></b-input>
               </b-form-group>
               <b-form-group
@@ -121,10 +121,11 @@
               >
               <b-form-select
                 required
-                v-model="formData.language"
+                v-model="selectedLanguage"
                 :options="languagesSelect"
                 name="language"
-                :disabled="formData.type !== 'custom'"
+                :disabled="!isEditableType(formData.type)"
+                @change="onLanguageChange"
               >
               </b-form-select>
               </b-form-group>
@@ -137,7 +138,7 @@
               v-model="formData.description"
               class="flex-grow-1"
               name="description"
-              :disabled="formData.type !== 'custom'"
+              :disabled="!isEditableType(formData.type)"
             ></b-textarea>
           </b-col>
         </b-row>
@@ -145,7 +146,7 @@
 
       <p class="mb-0">{{ $t("Docker file") }}</p>
 
-      <div class="d-flex flex-row mb-1">
+      <div v-if="formData.type !== 'realtime'" class="d-flex flex-row mb-1">
         <div class="mr-1">
           <a
             @click="showDockerfile = !showDockerfile"
@@ -177,7 +178,7 @@
       <b-form-textarea
         v-model="formData.config"
         class="mb-3 dockerfile"
-        :disabled="isRunning || formData.type !== 'custom'"
+        :disabled="isRunning || !isEditableType(formData.type)"
       >
       </b-form-textarea>
 
@@ -215,7 +216,7 @@
         </b-button>
 
         <b-button
-          v-if="showCancel && formData.type === 'custom'"
+          v-if="showCancel && isEditableType(formData.type)"
           :disabled="pidFile === null"
           variant="secondary"
           @click="cancel"
@@ -224,7 +225,7 @@
         </b-button>
 
         <b-button
-          v-if="showSave && formData.type === 'custom'"
+          v-if="showSave && isEditableType(formData.type)"
           :disabled="isRunning"
           variant="primary"
           @click="save()"
@@ -252,12 +253,14 @@ export default {
     "filter",
     "permission",
     "script_microservice_enabled",
+    "script_microservice_tenant_id",
   ],
   data() {
     return {
       commandOutput: "",
       languages: [],
       formData: null,
+      selectedLanguage: null,
       emptyFormData: {
         name: "",
         description: "",
@@ -271,7 +274,8 @@ export default {
       exitCode: 0,
       showDockerfile: false,
       loading: true,
-      script_microservice_broadcast_uui: null,
+      activeBuildUuid: null,
+      pendingBuildEvents: [],
 
       localLoadOnStart: true,
       orderBy: "language",
@@ -356,16 +360,15 @@ export default {
         }
       );
     }
+
+    if (this.script_microservice_enabled && this.script_microservice_tenant_id) {
+      this.subscribeToTenantBuildChannel();
+    }
   },
   watch: {
     commandOutput() {
       this.scrollToBottom();
     },
-    script_microservice_broadcast_uui(newVal) {
-      if (newVal) {
-        this.subscribeToScriptMicroserviceChannel(newVal);
-      }
-    },
   },
   computed: {
     modalTitle() {
@@ -389,19 +392,24 @@ export default {
     languagesSelect() {
       return [
         { value: null, text: this.$t("Select a language") },
-        ...this.languages,
+        ...this.languages.map((lang) => ({
+          value: lang.value,
+          text: lang.text,
+        })),
       ];
     },
+    selectedLanguageOption() {
+      if (!this.selectedLanguage) {
+        return null;
+      }
+      return this.languages.find((l) => l.value === this.selectedLanguage) || null;
+    },
     initDockerfile() {
       let content = "";
-      if (this.formData.language) {
-        content = _.get(
-          this.languages.find((l) => l.value === this.formData.language),
-          "initDockerfile",
-          ""
-        );
+      if (this.selectedLanguageOption) {
+        content = _.get(this.selectedLanguageOption, "initDockerfile", "");
       }
-      return content;
+      return content || "";
     },
   },
   methods: {
@@ -434,7 +442,13 @@ export default {
     },
     setErrors(errors) {
       this.status = "error";
-      this.errors = errors.response.data.errors;
+      this.errors = _.get(errors, "response.data.errors", {});
+      const messages = Object.values(this.errors)
+        .flat()
+        .filter((message) => typeof message === "string" && message !== "");
+      if (messages.length) {
+        this.output(messages.join("\n") + "\n");
+      }
     },
     doNotHideIfRunning(e) {
       if (this.isRunning) {
@@ -472,13 +486,15 @@ export default {
     save() {
       this.resetProcessInfo();
       this.status = "saving";
+      this.activeBuildUuid = this.formData.uuid || null;
+      this.pendingBuildEvents = [];
       if (this.formData.id) {
         const path = "/script-executors/" + this.formData.id;
         ProcessMaker.apiClient
           .put(path, this.formData)
           .then((result) => {
             this.status = _.get(result, "data.status", "error");
-            this.script_microservice_broadcast_uui = result.data.uuid;
+            this.setActiveBuildUuid(_.get(result, "data.uuid", this.formData.uuid));
           })
           .catch((e) => {
             this.setErrors(e);
@@ -489,9 +505,10 @@ export default {
           .post(path, this.formData)
           .then((result) => {
             this.status = _.get(result, "data.status", "error");
-            this.script_microservice_broadcast_uui = result.data.uuid;
+            this.setActiveBuildUuid(_.get(result, "data.uuid"));
             if (this.status === "started") {
               this.formData.id = result.data.id;
+              this.formData.uuid = result.data.uuid;
               this.fetch(); // refresh the table (beneath the modal)
             }
           })
@@ -505,13 +522,50 @@ export default {
     },
     edit(row) {
       this.formData = _.cloneDeep(row);
+      this.selectedLanguage = row.type === "realtime"
+        ? `${row.language}-realtime`
+        : row.language;
+      this.activeBuildUuid = row.uuid || null;
       this.$refs.edit.show();
     },
     reset() {
       this.formData = _.cloneDeep(this.emptyFormData);
+      this.selectedLanguage = null;
       this.errors = {};
       this.showDockerfile = false;
-      (this.status = "idle"), this.resetProcessInfo();
+      this.status = "idle";
+      this.activeBuildUuid = null;
+      this.pendingBuildEvents = [];
+      this.resetProcessInfo();
+    },
+    onLanguageChange(value) {
+      const option = this.languages.find((l) => l.value === value);
+      if (!option) {
+        this.formData.language = null;
+        this.formData.type = "custom";
+        return;
+      }
+      this.formData.language = option.language || option.value;
+      this.formData.type = option.realtime ? "realtime" : "custom";
+      if (!this.formData.id) {
+        this.formData.config = option.realtime
+          ? (option.configExample || "")
+          : "";
+      } else if (option.realtime && !this.formData.config && option.configExample) {
+        this.formData.config = option.configExample;
+      }
+    },
+    isEditableType(type) {
+      return type === "custom" || type === "realtime";
+    },
+    typeLabel(type) {
+      if (type === "realtime") {
+        return "Realtime";
+      }
+      if (type === "custom") {
+        return "Custom";
+      }
+      return "Base";
     },
     resetProcessInfo() {
       this.commandOutput = "";
@@ -550,31 +604,72 @@ export default {
     onAddToBundle(data) {
       this.$root.$emit('add-to-bundle', data);
     },
-    subscribeToScriptMicroserviceChannel(name) {
-      const channel = `build-image-${name}`;
-      if (this.script_microservice_enabled) {
-      // Subscribe to new channel
-        window.ScriptMicroserviceEcho
-          .channel(channel)
-          .listenToAll((eventName, data) => {
-            this.status = this.status === "idle" ? "starting" : this.status;
-            switch (eventName) {
-              case ".build-image":
-                this.output(`${data}\n`);
-                break;
-              case ".build-finished":
-                this.pidFile = null;
-                this.exitCode = 0;
-                this.status = "done";
-                break;
-              case ".build-error":
-                this.output(data);
-                this.pidFile = null;
-                this.exitCode = 1;
-                this.status = "done";
-                break;
-            }
-          });
+    subscribeToTenantBuildChannel() {
+      if (!window.ScriptMicroserviceEcho) {
+        return;
+      }
+      const channel = `tenant-${this.script_microservice_tenant_id}-builds`;
+      window.ScriptMicroserviceEcho.channel(channel).listen(
+        ".executor-build",
+        (data) => {
+          this.handleExecutorBuildEvent(data);
+        }
+      );
+    },
+    setActiveBuildUuid(uuid) {
+      if (!uuid) {
+        return;
+      }
+      this.activeBuildUuid = uuid;
+      const pending = this.pendingBuildEvents.filter(
+        (event) => event.executor_id === uuid
+      );
+      this.pendingBuildEvents = [];
+      pending.forEach((event) => this.applyExecutorBuildEvent(event));
+    },
+    handleExecutorBuildEvent(data) {
+      if (!data || typeof data !== "object") {
+        return;
+      }
+      if (!this.isRunning) {
+        return;
+      }
+      if (!this.activeBuildUuid) {
+        this.pendingBuildEvents.push(data);
+        return;
+      }
+      if (data.executor_id !== this.activeBuildUuid) {
+        return;
+      }
+      this.applyExecutorBuildEvent(data);
+    },
+    applyExecutorBuildEvent(data) {
+      if (this.status === "saving") {
+        this.status = "starting";
+      } else if (this.status === "idle") {
+        this.status = "starting";
+      }
+
+      if (data.type === "status") {
+        this.output(`[${data.phase}] ${data.message || ""}\n`);
+      } else if (data.message) {
+        const message = data.message.endsWith("\n")
+          ? data.message
+          : `${data.message}\n`;
+        this.output(message);
+      }
+
+      if (data.phase === "completed" && data.type === "status") {
+        this.pidFile = null;
+        this.exitCode = 0;
+        this.status = "done";
+        return;
+      }
+
+      if (data.phase === "error" || data.type === "error") {
+        this.pidFile = null;
+        this.exitCode = 1;
+        this.status = "done";
       }
     },
   },
diff --git a/resources/js/processes/scripts/components/ScriptEditor.vue b/resources/js/processes/scripts/components/ScriptEditor.vue
index 08060d18f8..2c42588603 100644
--- a/resources/js/processes/scripts/components/ScriptEditor.vue
+++ b/resources/js/processes/scripts/components/ScriptEditor.vue
@@ -299,7 +299,7 @@
                             {{ preview.error.exception }}
                           </div>
                           <pre class="text-light text-monospace small">{{
-                            preview.error.message
+                            formatErrorMessage(preview.error.message)
                           }}</pre>
                         </div>
                       </div>
@@ -357,6 +357,7 @@
           <span class="text-uppercase">{{ language }}</span>
         </span>
         <span class="ml-auto">
+          <span v-if="displayDuration" class="text-secondary text-sm">{{ displayDuration }}</span>
           <i
             v-if="preview.executing"
             class="fas fa-spinner fa-spin"
@@ -506,6 +507,7 @@ export default {
       lineContext: null,
       isDiffEditor: false,
       currentNonce: null,
+      duration: null,
       progress: {
         progress: 0,
       },
@@ -539,6 +541,25 @@ export default {
     };
   },
   computed: {
+    displayDuration() {
+      if (this.preview.executing) {
+        return null;
+      }
+
+      if (!this.preview.success && !this.preview.failure) {
+        return null;
+      }
+      
+      if (!this.duration && this.duration !== 0) return null;
+
+      if (this.duration < 1) {
+        // less than a second, show ms
+        return `${Math.round(this.duration * 1000)}ms`;
+      }
+      // 1s or more, show s with 2 decimals
+      return `${this.duration.toFixed(2)}s`;
+ 
+    },
     previewChanges() {
       return this.showDiffEditor || this.showExplainEditor;
     },
@@ -798,11 +819,34 @@ export default {
       }
       this.stringifyJson = JSON.stringify(output, null, 2);
     },
+    formatErrorMessage(value) {
+      if (value == null || value === "") {
+        return "";
+      }
+      if (typeof value === "string") {
+        return value;
+      }
+      try {
+        return JSON.stringify(value, null, 2);
+      } catch (e) {
+        return String(value);
+      }
+    },
+    setPreviewFailure(exception, message) {
+      this.preview.executing = false;
+      this.preview.success = false;
+      this.preview.failure = true;
+      this.preview.error.exception = exception;
+      this.preview.error.message = message;
+      this.outputOpen = true;
+    },
     outputResponse(response) {
       if (response.nonce !== this.nonce) {
         return;
       }
 
+      this.duration = response.duration;
+
       if (this.executionKey && this.executionKey !== response.data.watcher) {
         return;
       }
@@ -841,6 +885,11 @@ export default {
         nonce: this.nonce,
       }).then((response) => {
         this.executionKey = response.data.key;
+      }).catch((error) => {
+        this.setPreviewFailure(
+          error.response?.data?.exception || error.response?.status || "Error",
+          error.response?.data || error.message,
+        );
       });
     },
     save(onSuccess, onError, shouldRedirect = false) {
diff --git a/resources/script-executors/realtime/javascript.Dockerfile b/resources/script-executors/realtime/javascript.Dockerfile
new file mode 100644
index 0000000000..2a30a32801
--- /dev/null
+++ b/resources/script-executors/realtime/javascript.Dockerfile
@@ -0,0 +1,98 @@
+# syntax=docker/dockerfile:1
+# Realtime Node.js executor: fresh container per request via `docker run --rm -i`.
+#
+# The service pipes one JSON payload on stdin. bootstrap.js runs the script,
+# prints the JSON result on stdout, and exits. The container is removed on exit.
+
+FROM node:22-alpine
+
+COPY <<'EOF' /bootstrap.js
+#!/usr/bin/env node
+/**
+ * Read one JSON payload from stdin, run the script, print result, exit.
+ *
+ * Expected payload shape:
+ *   { "script": "...", "data": {}, "config": {}, "env": {} }
+ */
+
+'use strict';
+
+const fs = require('fs');
+
+function writeError(error, { code = 0, file = '', line = 0, trace = '' } = {}) {
+  process.stderr.write(
+    JSON.stringify({ error, code, file, line, trace }) + '\n'
+  );
+}
+
+/** Best-effort line/file from a Function/eval stack frame. */
+function locationFromError(e) {
+  const stack = typeof e.stack === 'string' ? e.stack : '';
+  // new Function bodies show up as <anonymous>:LINE:COL
+  const anon = stack.match(/<anonymous>:(\d+):(\d+)/);
+  if (anon) {
+    return { file: '<anonymous>', line: Number(anon[1]) || 0 };
+  }
+  return { file: '', line: 0 };
+}
+
+let raw = '';
+try {
+  raw = fs.readFileSync(0, 'utf8');
+} catch (e) {
+  process.stderr.write('No input on stdin\n');
+  process.exit(1);
+}
+
+if (!raw || !raw.trim()) {
+  process.stderr.write('No input on stdin\n');
+  process.exit(1);
+}
+
+let payload;
+try {
+  payload = JSON.parse(raw.trim());
+} catch (e) {
+  writeError(`Invalid JSON: ${e.message}`);
+  process.exit(1);
+}
+
+const script = payload.script;
+if (script === undefined || script === null || script === '') {
+  writeError('Missing "script" field');
+  process.exit(1);
+}
+
+// Available to the evaluated script (mirrors the PHP/Python convention).
+const data = payload.data ?? {};
+const config = payload.config ?? {};
+
+for (const [key, value] of Object.entries(payload.env ?? {})) {
+  if (value === null || value === undefined) {
+    process.env[key] = '';
+  } else if (typeof value === 'string' || typeof value === 'number' || typeof value === 'boolean') {
+    process.env[key] = String(value);
+  } else {
+    process.env[key] = JSON.stringify(value);
+  }
+}
+
+try {
+  // new Function so the user script can `return` a value, like PHP eval.
+  const fn = new Function('data', 'config', script);
+  const result = fn(data, config);
+  process.stdout.write(JSON.stringify(result) + '\n');
+  process.exit(0);
+} catch (e) {
+  const { file, line: errLine } = locationFromError(e);
+  writeError(e.message || String(e), {
+    code: typeof e.code === 'number' ? e.code : 0,
+    file,
+    line: errLine,
+    trace: typeof e.stack === 'string' ? e.stack : '',
+  });
+  process.exit(1);
+}
+EOF
+
+CMD ["node", "/bootstrap.js"]
diff --git a/resources/script-executors/realtime/php.Dockerfile b/resources/script-executors/realtime/php.Dockerfile
new file mode 100644
index 0000000000..4fa5466955
--- /dev/null
+++ b/resources/script-executors/realtime/php.Dockerfile
@@ -0,0 +1,85 @@
+# syntax=docker/dockerfile:1
+# Realtime PHP executor: fresh container per request via `docker run --rm -i`.
+#
+# The service pipes one JSON payload on stdin. bootstrap.php evals the script,
+# prints the JSON result on stdout, and exits. The container is removed on exit.
+
+FROM php:8.3-cli-alpine
+
+COPY <<'EOF' /bootstrap.php
+<?php
+/**
+ * Read one JSON payload from stdin, eval the script, print result, exit.
+ *
+ * Expected payload shape:
+ *   { "script": "...", "data": {}, "config": {}, "env": {} }
+ */
+
+$raw = file_get_contents('php://stdin');
+if ($raw === false || trim($raw) === '') {
+    fwrite(STDERR, "No input on stdin\n");
+    exit(1);
+}
+
+$payload = json_decode($raw, true);
+if (json_last_error() !== JSON_ERROR_NONE) {
+    fwrite(STDERR, json_encode([
+        'error' => 'Invalid JSON: ' . json_last_error_msg(),
+        'code' => 0,
+        'file' => '',
+        'line' => 0,
+        'trace' => '',
+    ], JSON_UNESCAPED_UNICODE) . "\n");
+    fflush(STDERR);
+    exit(1);
+}
+
+$script = $payload['script'] ?? null;
+if ($script === null || $script === '') {
+    fwrite(STDERR, json_encode([
+        'error' => 'Missing "script" field',
+        'code' => 0,
+        'file' => '',
+        'line' => 0,
+        'trace' => '',
+    ], JSON_UNESCAPED_UNICODE) . "\n");
+    fflush(STDERR);
+    exit(1);
+}
+
+// Available to the evaluated script (matches executor-php convention).
+$data = $payload['data'] ?? [];
+$config = $payload['config'] ?? [];
+
+foreach (($payload['env'] ?? []) as $key => $value) {
+    $stringValue = is_scalar($value) || $value === null ? (string) $value : json_encode($value);
+    putenv($key . '=' . $stringValue);
+    $_ENV[$key] = $stringValue;
+    $_SERVER[$key] = $stringValue;
+}
+
+// eval() does not accept opening tags.
+$script = preg_replace('/^<\?php\s*/i', '', trim($script));
+// ProcessMaker encodes ' as &#39; (classic executor shell quoting). Restore
+// before eval so `return ['x' => ...]` is not parsed as `return [&` + comment.
+$script = str_replace('&#39;', "'", $script);
+
+try {
+    $result = eval($script);
+    fwrite(STDOUT, json_encode($result, JSON_UNESCAPED_UNICODE) . "\n");
+    fflush(STDOUT);
+    exit(0);
+} catch (Throwable $e) {
+    fwrite(STDERR, json_encode([
+        'error' => $e->getMessage(),
+        'code' => $e->getCode(),
+        'file' => $e->getFile(),
+        'line' => $e->getLine(),
+        'trace' => $e->getTraceAsString(),
+    ], JSON_UNESCAPED_UNICODE) . "\n");
+    fflush(STDERR);
+    exit(1);
+}
+EOF
+
+CMD ["php", "/bootstrap.php"]
diff --git a/resources/script-executors/realtime/python.Dockerfile b/resources/script-executors/realtime/python.Dockerfile
new file mode 100644
index 0000000000..49327c9615
--- /dev/null
+++ b/resources/script-executors/realtime/python.Dockerfile
@@ -0,0 +1,122 @@
+# syntax=docker/dockerfile:1
+# Realtime Python executor: fresh container per request via `docker run --rm -i`.
+#
+# The service pipes one JSON payload on stdin. bootstrap.py execs the script,
+# prints the JSON result on stdout, and exits. The container is removed on exit.
+
+FROM python:3.12-alpine
+
+COPY <<'EOF' /bootstrap.py
+#!/usr/bin/env python3
+"""Read one JSON payload from stdin, exec the script, print result, exit.
+
+Expected payload shape:
+  { "script": "...", "data": {}, "config": {}, "env": {} }
+"""
+
+from __future__ import annotations
+
+import json
+import os
+import sys
+import textwrap
+import traceback
+
+
+def write_error(
+    error: str,
+    *,
+    code: int = 0,
+    file: str = "",
+    line: int = 0,
+    trace: str = "",
+) -> None:
+    print(
+        json.dumps(
+            {
+                "error": error,
+                "code": code,
+                "file": file,
+                "line": line,
+                "trace": trace,
+            },
+            ensure_ascii=False,
+        ),
+        file=sys.stderr,
+        flush=True,
+    )
+
+
+def main() -> int:
+    raw = sys.stdin.read()
+    if not raw or not raw.strip():
+        print("No input on stdin", file=sys.stderr)
+        return 1
+
+    try:
+        payload = json.loads(raw.strip())
+    except json.JSONDecodeError as e:
+        write_error(f"Invalid JSON: {e}")
+        return 1
+
+    script = payload.get("script")
+    if not script:
+        write_error('Missing "script" field')
+        return 1
+
+    # Available to the evaluated script (mirrors the PHP convention).
+    data = payload.get("data") or {}
+    config = payload.get("config") or {}
+
+    for key, value in (payload.get("env") or {}).items():
+        if value is None or isinstance(value, (str, int, float, bool)):
+            os.environ[str(key)] = "" if value is None else str(value)
+        else:
+            os.environ[str(key)] = json.dumps(value)
+
+    # Wrap so the user script can `return` a value, like PHP eval.
+    # Leading "def" line shifts user line numbers by +1; we subtract it when reporting.
+    wrapped = "def __user_script__():\n" + textwrap.indent(script.strip(), "    ")
+    namespace: dict = {"data": data, "config": config}
+
+    try:
+        compiled = compile(wrapped, "<script>", "exec")
+        exec(compiled, namespace)
+        result = namespace["__user_script__"]()
+        print(json.dumps(result, ensure_ascii=False), flush=True)
+        return 0
+    except Exception as e:
+        file = ""
+        err_line = 0
+        if isinstance(e, SyntaxError):
+            file = e.filename or "<script>"
+            err_line = max(0, (e.lineno or 0) - 1)
+        else:
+            frames = traceback.extract_tb(e.__traceback__)
+            for frame in reversed(frames):
+                if frame.filename == "<script>":
+                    file = frame.filename
+                    err_line = (
+                        max(0, frame.lineno - 1)
+                        if frame.name == "__user_script__"
+                        else frame.lineno
+                    )
+                    break
+            else:
+                if frames:
+                    file = frames[-1].filename
+                    err_line = frames[-1].lineno
+        write_error(
+            str(e),
+            file=file,
+            line=err_line,
+            trace=traceback.format_exc(),
+        )
+        return 1
+
+
+if __name__ == "__main__":
+    raise SystemExit(main())
+EOF
+
+CMD ["python", "-u", "/bootstrap.py"]
diff --git a/resources/views/admin/script-executors/index.blade.php b/resources/views/admin/script-executors/index.blade.php
index cb3146fabe..bc70a1ddfb 100644
--- a/resources/views/admin/script-executors/index.blade.php
+++ b/resources/views/admin/script-executors/index.blade.php
@@ -19,6 +19,7 @@
         <div class="card card-body">
             <script-executors
                     :script_microservice_enabled="@json($script_microservice_enabled)"
+                    script_microservice_tenant_id="{{$script_microservice_tenant_id}}"
             ></script-executors>
         </div>
     </div>
diff --git a/resources/views/processes/scripts/builder.blade.php b/resources/views/processes/scripts/builder.blade.php
index faa4df2de0..5a5e6c9819 100644
--- a/resources/views/processes/scripts/builder.blade.php
+++ b/resources/views/processes/scripts/builder.blade.php
@@ -22,7 +22,7 @@
   <div id="script-container">
     <script-editor 
       :script="{{ $script }}" 
-      :script-executor='{!! json_encode($script->scriptExecutor) !!}'
+      :script-executor='{!! json_encode(Arr::except($script->scriptExecutor, 'config')) !!}'
       test-data="{{ json_encode($testData, JSON_PRETTY_PRINT) }}" 
       :auto-save-delay="{{ $autoSaveDelay }}"
       :is-versions-installed="@json($isVersionsInstalled)" 
diff --git a/resources/views/processes/scripts/preview.blade.php b/resources/views/processes/scripts/preview.blade.php
index 446706a5d7..4bd93f035f 100644
--- a/resources/views/processes/scripts/preview.blade.php
+++ b/resources/views/processes/scripts/preview.blade.php
@@ -12,7 +12,7 @@
             <div class="col-12">
                 <script-preview
                         :script="{{ $script }}"
-                        :script-executor='{!! json_encode($script->scriptExecutor) !!}'
+                        :script-executor='{!! json_encode(Arr::except($script->scriptExecutor, 'config')) !!}'
                         test-data="{{ json_encode($testData, JSON_PRETTY_PRINT) }}"
                         :auto-save-delay="{{ $autoSaveDelay }}"
                         :is-versions-installed="@json($isVersionsInstalled)"
diff --git a/tests/Feature/Api/ScriptsTest.php b/tests/Feature/Api/ScriptsTest.php
index bb76dad7db..a991307481 100644
--- a/tests/Feature/Api/ScriptsTest.php
+++ b/tests/Feature/Api/ScriptsTest.php
@@ -6,10 +6,13 @@
 use Faker\Factory as Faker;
 use Illuminate\Support\Carbon;
 use Illuminate\Support\Facades\Event;
+use Illuminate\Support\Facades\Queue;
+use ProcessMaker\Enums\ScriptExecutorType;
 use ProcessMaker\Events\ScriptResponseEvent;
 use ProcessMaker\Exception\ScriptLanguageNotSupported;
 use ProcessMaker\Facades\WorkflowManager;
 use ProcessMaker\Jobs\ImportProcess;
+use ProcessMaker\Jobs\TestScript;
 use ProcessMaker\Models\Process;
 use ProcessMaker\Models\ProcessRequestToken;
 use ProcessMaker\Models\Screen;
@@ -396,6 +399,31 @@ public function testPreviewScript()
         });
     }
 
+    public function testRealtimePreviewUsesRealtimeQueue()
+    {
+        Queue::fake();
+        $executor = ScriptExecutor::factory()->create([
+            'language' => 'php',
+            'type' => ScriptExecutorType::Realtime,
+        ]);
+        $script = Script::factory()->create([
+            'run_as_user_id' => $this->user->id,
+            'language' => 'php',
+            'script_executor_id' => $executor->id,
+        ]);
+
+        $response = $this->apiCall('POST', route('api.scripts.preview', $script), [
+            'data' => '{}',
+            'code' => '<?php return ["response" => 1];',
+            'nonce' => '123abc',
+        ]);
+
+        $response->assertOk()->assertJson(['status' => 'success']);
+        Queue::assertPushed(TestScript::class, function (TestScript $job) {
+            return $job->connection === 'redis-realtime' && $job->queue === 'realtime';
+        });
+    }
+
     /**
      * Test the preview function
      */
diff --git a/tests/Jobs/RunScriptTaskTest.php b/tests/Jobs/RunScriptTaskTest.php
index 6e44152f95..5be9b0c53a 100644
--- a/tests/Jobs/RunScriptTaskTest.php
+++ b/tests/Jobs/RunScriptTaskTest.php
@@ -6,6 +6,7 @@
 use Illuminate\Support\Facades\Queue;
 use Mockery;
 use PHPUnit\Framework\Attributes\DataProvider;
+use ProcessMaker\Enums\ScriptExecutorType;
 use ProcessMaker\Facades\WorkflowManager;
 use ProcessMaker\Jobs\ErrorHandling;
 use ProcessMaker\Jobs\RunNayraScriptTask;
@@ -14,11 +15,45 @@
 use ProcessMaker\Models\ProcessRequest;
 use ProcessMaker\Models\ProcessRequestToken;
 use ProcessMaker\Models\Script;
+use ProcessMaker\Models\ScriptExecutor;
 use ProcessMaker\Models\User;
+use ProcessMaker\Nayra\Contracts\Bpmn\ScriptTaskInterface;
+use ProcessMaker\Nayra\Managers\WorkflowManagerDefault;
 use Tests\TestCase;
 
 class RunScriptTaskTest extends TestCase
 {
+    public function testRealtimeScriptTaskUsesRealtimeQueue()
+    {
+        Queue::fake();
+        $process = Process::factory()->create();
+        $request = ProcessRequest::factory()->create([
+            'process_id' => $process->id,
+        ]);
+        $token = ProcessRequestToken::factory()->create([
+            'process_request_id' => $request->id,
+        ]);
+        $executor = ScriptExecutor::factory()->create([
+            'language' => 'php',
+            'type' => ScriptExecutorType::Realtime,
+        ]);
+        $script = Script::factory()->create([
+            'script_executor_id' => $executor->id,
+        ]);
+        $scriptTask = Mockery::mock(ScriptTaskInterface::class);
+        $scriptTask->shouldReceive('getId')->once()->andReturn('script-task');
+        $scriptTask->shouldReceive('getProperty')
+            ->once()
+            ->with('scriptRef')
+            ->andReturn($script->id);
+
+        (new WorkflowManagerDefault())->runScripTask($scriptTask, $token);
+
+        Queue::assertPushed(RunScriptTask::class, function (RunScriptTask $job) {
+            return $job->connection === 'redis-realtime' && $job->queue === 'realtime';
+        });
+    }
+
     #[DataProvider('jobTypes')]
     public function testScriptNotSet($class)
     {
diff --git a/tests/Jobs/TestScriptTest.php b/tests/Jobs/TestScriptTest.php
new file mode 100644
index 0000000000..341dc6ab21
--- /dev/null
+++ b/tests/Jobs/TestScriptTest.php
@@ -0,0 +1,88 @@
+<?php
+
+namespace Tests\Jobs;
+
+use Illuminate\Support\Facades\Event;
+use ProcessMaker\Enums\ScriptExecutorType;
+use ProcessMaker\Events\ScriptResponseEvent;
+use ProcessMaker\Jobs\TestScript;
+use ProcessMaker\Models\Script;
+use ProcessMaker\Models\ScriptExecutor;
+use ProcessMaker\Models\User;
+use Tests\TestCase;
+
+class TestScriptTest extends TestCase
+{
+    public function testRealtimeExecutorBroadcastsOnlyTheScriptOutput()
+    {
+        config(['script-runner-microservice.enabled' => true]);
+        Event::fake([ScriptResponseEvent::class]);
+
+        $script = $this->realtimeScript([
+            'status' => 'success',
+            'metadata' => ['script_id' => 24, 'executor_type' => 'realtime'],
+            'output' => ['response' => 1],
+        ]);
+
+        (new TestScript($script, $this->previewUser(), 'return [];', [], [], '123abc'))->handle();
+
+        Event::assertDispatched(ScriptResponseEvent::class, function (ScriptResponseEvent $event) {
+            return $event->status === 200
+                && $event->response === ['output' => ['response' => 1]]
+                && $event->nonce === '123abc';
+        });
+    }
+
+    public function testRealtimeExecutorBroadcastsFailureAsException()
+    {
+        config(['script-runner-microservice.enabled' => true]);
+        Event::fake([ScriptResponseEvent::class]);
+
+        $script = $this->realtimeScript([
+            'status' => 'error',
+            'metadata' => ['script_id' => 24],
+            'error' => 'Syntax error, unexpected token',
+        ]);
+
+        (new TestScript($script, $this->previewUser(), 'return [];', [], [], '123abc'))->handle();
+
+        Event::assertDispatched(ScriptResponseEvent::class, function (ScriptResponseEvent $event) {
+            return $event->status === 500
+                && $event->response['message'] === 'Syntax error, unexpected token'
+                && !array_key_exists('metadata', $event->response);
+        });
+    }
+
+    private function realtimeScript(array $microserviceResponse): Script
+    {
+        return new class($microserviceResponse) extends Script {
+            private array $microserviceResponse;
+
+            public function __construct(array $microserviceResponse = [])
+            {
+                parent::__construct();
+                $this->microserviceResponse = $microserviceResponse;
+            }
+
+            public function getScriptExecutorAttribute()
+            {
+                return new ScriptExecutor([
+                    'type' => ScriptExecutorType::Realtime,
+                ]);
+            }
+
+            public function runScript(array $data, array $config, $tokenId = '', $timeout = null, $sync = 1, $metadata = [])
+            {
+                return $this->microserviceResponse;
+            }
+        };
+    }
+
+    private function previewUser(): User
+    {
+        $user = new User();
+        $user->id = 123;
+
+        return $user;
+    }
+}
diff --git a/tests/unit/ProcessMaker/Services/ScriptMicroserviceServiceTest.php b/tests/unit/ProcessMaker/Services/ScriptMicroserviceServiceTest.php
index e5cebe89ac..edb69292d3 100644
--- a/tests/unit/ProcessMaker/Services/ScriptMicroserviceServiceTest.php
+++ b/tests/unit/ProcessMaker/Services/ScriptMicroserviceServiceTest.php
@@ -87,7 +87,9 @@ public function testCreateCustomExecutor()
                 && isset($request->data()['id'])
                 && $request->data()['name'] === 'Test Executor'
                 && $request->data()['language'] === 'php'
-                && $request->data()['version'] === '1.0.0';
+                && $request->data()['version'] === '1.0.0'
+                && array_key_exists('realtime', $request->data())
+                && $request->data()['realtime'] === false;
         });
 
         $this->assertEquals('test-executor-uuid', $result['id']);
@@ -130,7 +132,8 @@ public function testUpdateCustomExecutor()
                 && $request->hasHeader('Authorization', 'Bearer ' . $this->accessToken)
                 && $request->data()['name'] === 'Updated Executor'
                 && $request->data()['language'] === 'javascript'
-                && $request->data()['version'] === '1.0.0';
+                && $request->data()['version'] === '1.0.0'
+                && array_key_exists('realtime', $request->data());
         });
 
         $this->assertEquals('test-executor-uuid', $result['id']);