fix(python): fix max_duration conversion and disable bytecode cache in dev

Author: beydogan

package.json

@@ -36,6 +36,7 @@
     "clean:node_modules": "find . -name 'node_modules' -type d -prune -exec rm -rf '{}' +",
     "clean:python": "find . -name '*.pyc' -delete && find . -name '__pycache__' -type d -exec rm -rf '{}' + 2>/dev/null || true",
     "clean:all": "pnpm run clean && pnpm run clean:python",
+    "rebuild:cli": "pnpm run clean:python && pnpm run build --filter trigger.dev",
     "typecheck": "turbo run typecheck",
     "test:e2e": "playwright test",
     "test:e2e:ui": "playwright test --ui",

packages/cli-v3/src/entryPoints/python/managed-index-worker.py

@@ -99,7 +99,9 @@ def collect_task_metadata() -> List[Dict[str, Any]]:
             if task_meta.queue:
                 task_dict["queue"] = task_meta.queue.model_dump()
             if task_meta.maxDuration is not None:
+                # Already in milliseconds from task decorator
                 task_dict["maxDuration"] = task_meta.maxDuration
+                logger.debug(f"Task {task_id} maxDuration: {task_meta.maxDuration}ms")
 
             tasks.append(task_dict)
             logger.debug(f"Collected task: {task_id}")

packages/cli-v3/src/indexing/indexWorkerManifest.ts

@@ -50,6 +50,7 @@ export async function indexWorkerManifest({
         TRIGGER_BUILD_MANIFEST_PATH: buildManifestPath,
         NODE_OPTIONS: nodeOptions,
         TRIGGER_INDEXING: "1",
+        PYTHONDONTWRITEBYTECODE: "1", // Disable .pyc files in dev to avoid stale cache
       },
       execPath: execPathForRuntime(runtime),
     });

packages/cli-v3/src/ipc/grpcServer.ts

@@ -140,8 +140,13 @@ export class GrpcWorkerServer extends EventEmitter {
       ...(logMessage.exception && { exception: logMessage.exception }),
     };
 
+    // Normalize log level to number (protobuf sends enum as string name)
+    const level = typeof logMessage.level === 'string'
+      ? LogLevel[logMessage.level as keyof typeof LogLevel]
+      : logMessage.level;
+
     // Route to appropriate log level
-    switch (logMessage.level) {
+    switch (level) {
       case LogLevel.DEBUG:
         logger.debug('Python worker', logData);
         break;
@@ -158,7 +163,7 @@ export class GrpcWorkerServer extends EventEmitter {
         }
         break;
       default:
-        logger.info('Python worker', logData);
+        logger.warn('Python worker (unknown log level)', { ...logData, receivedLevel: logMessage.level });
     }
   }
 

packages/cli-v3/src/python/pythonProcess.ts

@@ -54,6 +54,7 @@ export class PythonProcess {
           ...process.env,
           ...this.options.env,
           PYTHONUNBUFFERED: "1",
+          PYTHONDONTWRITEBYTECODE: "1", // Disable .pyc files in dev to avoid stale cache
           TRIGGER_GRPC_ADDRESS: grpcAddress,
         },
         stdio: ["pipe", "pipe", "pipe"],

packages/cli-v3/src/python/pythonTaskRunner.ts

@@ -113,9 +113,17 @@ export class PythonTaskRunner {
 
       // Wait for completion or failure
       const result = await new Promise<TaskRunExecutionResult>((resolve, reject) => {
+        // execution.run.maxDuration is in SECONDS from the platform, convert to milliseconds
+        const maxDurationMs = execution.run.maxDuration
+          ? execution.run.maxDuration * 1000
+          : 300000;
+        logger.debug(`Setting task timeout to ${maxDurationMs}ms (${maxDurationMs/1000}s)`, {
+          maxDuration: execution.run.maxDuration,
+          runId: execution.run.id,
+        });
         const timeout = setTimeout(() => {
           reject(new Error("Task execution timeout"));
-        }, execution.run.maxDuration ?? 300000);
+        }, maxDurationMs);
 
         grpcServer.on("TASK_RUN_COMPLETED", (message: any) => {
           clearTimeout(timeout);

packages/python-sdk/trigger_sdk/task.py

@@ -88,11 +88,14 @@ async def my_task(payload):
     retry_config = RetryConfig(**retry) if isinstance(retry, dict) else retry
     queue_config = QueueConfig(**queue) if isinstance(queue, dict) else queue
 
+    # Convert max_duration from seconds to milliseconds (TypeScript expects ms)
+    max_duration_ms = max_duration * 1000 if max_duration is not None else None
+
     config = TaskConfig(
         id=id,
         retry=retry_config,
         queue=queue_config,
-        maxDuration=max_duration,
+        maxDuration=max_duration_ms,
     )
 
     def decorator(fn: Callable[..., Any]) -> Task:

packages/python-sdk/trigger_sdk/types.py

@@ -24,7 +24,7 @@ class TaskConfig(BaseModel):
     id: str
     retry: Optional[RetryConfig] = None
     queue: Optional[QueueConfig] = None
-    maxDuration: Optional[int] = None  # seconds
+    maxDuration: Optional[int] = None  # milliseconds (converted from seconds in decorator)
 
 
 class TaskMetadata(BaseModel):