-
Notifications
You must be signed in to change notification settings - Fork 698
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
Log streaming response #4776
Log streaming response #4776
Conversation
Signed-off-by: Kevin Su <[email protected]>
Signed-off-by: Kevin Su <[email protected]>
Signed-off-by: Kevin Su <[email protected]>
Signed-off-by: Kevin Su <[email protected]>
Signed-off-by: Haytham Abuelfutuh <[email protected]>
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## master #4776 +/- ##
==========================================
- Coverage 58.21% 58.19% -0.02%
==========================================
Files 626 626
Lines 53855 53950 +95
==========================================
+ Hits 31349 31394 +45
- Misses 19996 20045 +49
- Partials 2510 2511 +1
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
// The execution log results. | ||
string results = 1; | ||
oneof part { | ||
GetTaskLogsResponseHeader header = 1; |
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.
Does the response pattern end up looking like
GetTaskLogsResponse{Header{token=3}}
GetTaskLogsResponse{Body{results=[...]}} // 3 log lines
GetTaskLogsResponse{Header{token=9}
GetTaskLogsResponse{Body{results=[...]}} // 6 log lines
And then a future request call would include token=9
?
@@ -160,8 +160,18 @@ message GetTaskLogsRequest { | |||
bytes resource_meta = 2; | |||
} |
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.
We want token and limit here as well, right?
Cleaning stale PRs. Please reopen if you wan to discuss this further. |
Tracking issue
https://github.com/flyteorg/flyte/issues/
Why are the changes needed?
What changes were proposed in this pull request?
How was this patch tested?
Setup process
Screenshots
Check all the applicable boxes
Related PRs
Docs link