-
Notifications
You must be signed in to change notification settings - Fork 53
Create a FileOutput reader if the agent produce file output #391
Conversation
Signed-off-by: Kevin Su <[email protected]>
Codecov ReportPatch coverage:
Additional details and impacted files@@ Coverage Diff @@
## master #391 +/- ##
==========================================
+ Coverage 63.01% 64.19% +1.17%
==========================================
Files 154 156 +2
Lines 13080 10689 -2391
==========================================
- Hits 8243 6862 -1381
+ Misses 4220 3205 -1015
- Partials 617 622 +5
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]>
Signed-off-by: Kevin Su <[email protected]>
Signed-off-by: Kevin Su <[email protected]>
Signed-off-by: Kevin Su <[email protected]>
cc @hamersaw would you mind taking a look |
Signed-off-by: Kevin Su <[email protected]>
} | ||
|
||
if taskTemplate.Interface == nil || taskTemplate.Interface.Outputs == nil || taskTemplate.Interface.Outputs.Variables == nil { | ||
logger.Infof(ctx, "The task declares no outputs. Skipping writing the outputs.") |
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.
Can we make this debug too?
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.
done
Signed-off-by: Kevin Su <[email protected]>
Signed-off-by: Kevin Su <[email protected]>
TL;DR
Fixed https://flyte-org.slack.com/archives/C05GQ16TQLF/p1692227368597599
Create a
RemoteFileOutputReader
in the agent plugin if the task writes the output to the blob store.For example, an agent may submit a job to aws batch, which will write the output to s3, so we should add a file output reader to task context.
Type
Are all requirements met?
Complete description
^^^
Tracking Issue
NA
Follow-up issue
NA