[release] stream the full anyscale log to buildkite (ray-project#47808)

Currently we only print 100 last lines of anyscale job log to buildkite. This PR removes that limit and prints everything instead. CC: @kouroshHakha Test: - CI Signed-off-by: can <[email protected]> Signed-off-by: ujjawal-khare <[email protected]>
ujjawal-khare-27 · Oct 15, 2024 · a665c67 · a665c67
1 parent 2b21a08
commit a665c67
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/release/ray_release/job_manager/anyscale_job_manager.py b/release/ray_release/job_manager/anyscale_job_manager.py
@@ -273,7 +273,11 @@ def _get_ray_logs(self) -> str:
         """
         Obtain the last few logs
         """
-        return anyscale.job.get_logs(id=self.job_id, max_lines=LAST_LOGS_LENGTH)
+        if self.cluster_manager.log_streaming_limit == -1:
+            return anyscale.job.get_logs(id=self.job_id)
+        return anyscale.job.get_logs(
+            id=self.job_id, max_lines=self.cluster_manager.log_streaming_limit
+        )
 
     def get_last_logs(self):
         if not self.job_id: