Limit output logs to only 10 items

Flared · Jul 28, 2023 · 2a67792 · 2a67792
1 parent 699587f
commit 2a67792
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/saturn_engine/worker/services/loggers/logger.py b/src/saturn_engine/worker/services/loggers/logger.py
@@ -174,7 +174,8 @@ def published_data(self, event: MessagePublished) -> dict[str, t.Any]:
 
     def result_data(self, results: PipelineResults) -> dict[str, t.Any]:
         return {
-            "output": [self.output_data(o) for o in results.outputs],
+            "output": [self.output_data(o) for o in results.outputs[:10]],
+            "output_count": len(results.outputs),
             "resources": self.resources_used(results.resources),
         }