diff --git a/runagent-ts/src/client/index.ts b/runagent-ts/src/client/index.ts
index a47664b..2afc1bb 100644
--- a/runagent-ts/src/client/index.ts
+++ b/runagent-ts/src/client/index.ts
@@ -73,6 +73,12 @@ const getEnvVar = (name: string): string | undefined => {
   return undefined;
 };
 
+const parseEnvBool = (name: string): boolean | undefined => {
+  const val = getEnvVar(name);
+  if (val === undefined) return undefined;
+  return val.toLowerCase() === 'true' || val === '1';
+};
+
 export class RunAgentClient {
   private serializer: CoreSerializer;
   private local: boolean;
@@ -91,6 +97,8 @@ export class RunAgentClient {
   private timeoutSeconds: number;
   private extraParams?: Record<string, unknown>;
   private enableRegistry: boolean;
+  private _userId?: string;
+  private _persistentMemory: boolean;
 
   constructor(config: RunAgentConfig) {
     this.serializer = new CoreSerializer();
@@ -105,6 +113,8 @@ export class RunAgentClient {
     this.apiKey = config.apiKey ?? getEnvVar(API_KEY_ENV);
     this.baseUrl = config.baseUrl ?? getEnvVar(BASE_URL_ENV);
     this.baseSocketUrl = config.baseSocketUrl;
+    this._userId = config.userId ?? getEnvVar('RUNAGENT_USER_ID');
+    this._persistentMemory = config.persistentMemory ?? parseEnvBool('RUNAGENT_PERSISTENT_MEMORY') ?? false;
 
     if (!this.baseUrl && !this.local) {
       this.baseUrl = DEFAULT_REMOTE_BASE_URL;
@@ -354,7 +364,9 @@ export class RunAgentClient {
         inputArgs: [],
         inputKwargs,
         timeoutSeconds: this.timeoutSeconds,
-      }
+      },
+      this._userId,
+      this._persistentMemory
     );
 
     if (response.success !== false) {
@@ -405,7 +417,9 @@ export class RunAgentClient {
         inputArgs: [],
         inputKwargs,
         timeoutSeconds: this.timeoutSeconds,
-      }
+      },
+      this._userId,
+      this._persistentMemory
     );
   }
 
@@ -429,6 +443,14 @@ export class RunAgentClient {
     return this.extraParams;
   }
 
+  getUserId(): string | undefined {
+    return this._userId;
+  }
+
+  getPersistentMemory(): boolean {
+    return this._persistentMemory;
+  }
+
   /**
    * Check if registry features are available.
    */
diff --git a/runagent-ts/src/rest/index.ts b/runagent-ts/src/rest/index.ts
index f9ce927..62c201e 100644
--- a/runagent-ts/src/rest/index.ts
+++ b/runagent-ts/src/rest/index.ts
@@ -49,7 +49,9 @@ export class RestClient {
   async runAgent(
     agentId: string,
     entrypointTag: string,
-    options: RunAgentOptions = {}
+    options: RunAgentOptions = {},
+    userId?: string,
+    persistentMemory?: boolean
   ): Promise<ApiResponse> {
     const {
       inputArgs = [],
@@ -57,20 +59,29 @@ export class RestClient {
       timeoutSeconds = this.defaultTimeoutSeconds,
     } = options;
 
-      const requestData = {
+      const requestData: Record<string, unknown> = {
       entrypoint_tag: entrypointTag,
           input_args: inputArgs,
           input_kwargs: inputKwargs,
       timeout_seconds: timeoutSeconds,
       async_execution: false,
-      } as JsonValue;
+      };
+
+      if (userId) {
+        requestData.user_id = userId;
+      }
+      if (persistentMemory !== undefined) {
+        requestData.persistent_memory = persistentMemory;
+      }
+
+      const typedRequestData = requestData as JsonValue;
       
     const timeoutMs = timeoutSeconds * 1000 + 10_000; // Add buffer similar to Python SDK
 
       try {
         const response = await this.http.post(
         `/agents/${agentId}/run`,
-          requestData,
+          typedRequestData,
         { timeout: timeoutMs }
       );
 
diff --git a/runagent-ts/src/types/index.ts b/runagent-ts/src/types/index.ts
index a139c3e..d069e48 100644
--- a/runagent-ts/src/types/index.ts
+++ b/runagent-ts/src/types/index.ts
@@ -11,6 +11,8 @@ export interface RunAgentConfig {
   timeoutSeconds?: number;
   extraParams?: Record<string, unknown>;
   enableRegistry?: boolean;
+  userId?: string;
+  persistentMemory?: boolean;
 }
   
 export interface ApiResponse<T = JsonValue> {
@@ -61,6 +63,8 @@ export interface ExecutionRequest {
   input_kwargs: Record<string, unknown>;
   timeout_seconds?: number;
   async_execution?: boolean;
+  user_id?: string;
+  persistent_memory?: boolean;
 }
   
 export interface SerializedObject {
diff --git a/runagent-ts/src/websocket/base.ts b/runagent-ts/src/websocket/base.ts
index bbda23f..1f7ddd3 100644
--- a/runagent-ts/src/websocket/base.ts
+++ b/runagent-ts/src/websocket/base.ts
@@ -57,7 +57,9 @@ export abstract class BaseWebSocketClient {
   async *runStream(
     agentId: string,
     entrypointTag: string,
-    options: RunStreamOptions = {}
+    options: RunStreamOptions = {},
+    userId?: string,
+    persistentMemory?: boolean
   ): AsyncGenerator<unknown, void, unknown> {
     const { inputArgs = null, inputKwargs = null, timeoutSeconds } = options;
     const endpoint = `${this.baseSocketUrl}/agents/${agentId}/run-stream`;
@@ -87,6 +89,13 @@ export abstract class BaseWebSocketClient {
         async_execution: false,
       };
 
+      if (userId) {
+        request.user_id = userId;
+      }
+      if (persistentMemory !== undefined) {
+        request.persistent_memory = persistentMemory;
+      }
+
       this.sendMessage(websocket, JSON.stringify(request));
 
       yield* this.createWebSocketIterator(websocket);