fix

fal-ai · Oct 22, 2024 · 16ec00b · 16ec00b
1 parent ba97ef5
commit 16ec00b
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/src/isolate/server/server.py b/src/isolate/server/server.py
@@ -173,7 +173,7 @@ class RunTask:
     future: futures.Future | None = None
     agent: RunnerAgent | None = None
     logger: IsolateLogger = field(default_factory=IsolateLogger.from_env)
-    stream_logs: bool = False
+    stream_logs: bool = True
 
     def cancel(self):
         while True:
@@ -360,9 +360,8 @@ def SetMetadata(
 
     def set_metadata(self, task: RunTask, metadata: definitions.TaskMetadata) -> None:
         task.logger.extra_labels = dict(metadata.logger_labels)
-
-        if metadata.HasField("stream_logs"):
-            task.stream_logs = metadata.stream_logs
+        # Stream_logs defaults to False if not set
+        task.stream_logs = metadata.stream_logs
 
     def Run(
         self,