-
Notifications
You must be signed in to change notification settings - Fork 674
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Streaming log for agent #4767
base: master
Are you sure you want to change the base?
Streaming log for agent #4767
Conversation
Signed-off-by: Kevin Su <[email protected]>
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## master #4767 +/- ##
==========================================
- Coverage 58.21% 58.20% -0.01%
==========================================
Files 626 626
Lines 53855 53950 +95
==========================================
+ Hits 31349 31402 +53
- Misses 19996 20038 +42
Partials 2510 2510
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
Signed-off-by: Kevin Su <[email protected]>
Signed-off-by: Kevin Su <[email protected]>
@@ -23,7 +23,7 @@ service AsyncAgentService { | |||
rpc GetTaskMetrics(flyteidl.admin.GetTaskMetricsRequest) returns (flyteidl.admin.GetTaskMetricsResponse){}; | |||
|
|||
// GetTaskLogs returns task execution logs, if available. | |||
rpc GetTaskLogs(flyteidl.admin.GetTaskLogsRequest) returns (flyteidl.admin.GetTaskLogsResponse){}; | |||
rpc GetTaskLogs(flyteidl.admin.GetTaskLogsRequest) returns (stream flyteidl.admin.GetTaskLogsResponse){}; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What does the usage pattern look like here? GetTaskLogsResponse
contains a list of string results + a page token
Signed-off-by: Kevin Su <[email protected]>
converted to draft since Hattham has another pr to update the proto |
Tracking issue
#3936
Why are the changes needed?
Use streaming response for the
getLogs
API since users don't want to pull all the logs in the one gRPC call.What changes were proposed in this pull request?
Update response of
GetTaskLogs
tostream flyteidl.admin.GetTaskLogsResponse
Check all the applicable boxes