-
Notifications
You must be signed in to change notification settings - Fork 61
Cache eviction for single execution in datacatalog and flyteadmin #318
Cache eviction for single execution in datacatalog and flyteadmin #318
Conversation
5f04b6e
to
a7e386c
Compare
a7e386c
to
cf80598
Compare
Codecov Report
@@ Coverage Diff @@
## master #318 +/- ##
=======================================
Coverage 75.46% 75.46%
=======================================
Files 18 18
Lines 1174 1174
=======================================
Hits 886 886
Misses 237 237
Partials 51 51
Flags with carried forward coverage won't be shown. Click here to find out more.
Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here. |
Pushed additional IDL changes for flyteadmin, title/initial description have been adapted accordingly. |
8da6991
to
7bb56c0
Compare
hey @MorpheusXAUT this change looks good but I'm curious if you're planning on implementing the back-end changes to also include cache eviction and skipping the cache in the same PR per component. maybe it would make more sense to split these changes out individually (eviction & skipping) also, before merging this would it be possible to have the other back-end PRs prepared and tested end to end to reduce churn in updating flyteidl (especially when it comes to potentially having to deprecate proto fields if the message structure ends up changing over the course of your testing) |
Hi @katrogan , thanks for taking a look!
Yeah, I was planning on making a PR about skipping cache only (and everything that's required for that) and open another one for the second part of the implementing (evicting cached data).
Sure thing! I'm mostly done with the other PRs, currently finishing up flytectl and flyteconsole client implementations. The rest of the backend implementation is done, I'll open PRs for those tomorrow (using I'll mention this PR in the others as well so you'll have a quick overview of all changes once they're open. |
@katrogan All other PRs have been submitted, created as drafts for now since they depend on this PR/each other. Pushed some minor changes to protos as well today as they were required for the |
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.
Left a few comments on the flytepropeller PR - Basically, I'm concerned about using skipCache
for the naming of this feature. Really we are skipping the cache lookup but overwriting the existing cache values - would overwriteCache
be a better indicator of the functionality? I think leaving CACHE_SKIPPED
status during the lookup is correct and the rest of this PR lgtm. Open for discussion on this.
Existing artifacts can have their associated ArtifactData overwritten Signed-off-by: Nick Müller <[email protected]>
Signed-off-by: Nick Müller <[email protected]>
…owExecutionConfig Signed-off-by: Nick Müller <[email protected]>
Signed-off-by: Nick Müller <[email protected]>
Signed-off-by: Nick Müller <[email protected]>
Signed-off-by: Nick Müller <[email protected]>
1172311
to
52483c7
Compare
…yteorg#318) * Added datacatalog endpoint for updating artifacts Existing artifacts can have their associated ArtifactData overwritten Signed-off-by: Nick Müller <[email protected]> * datacatalog.UpdateArtifact returns ArtifactID Signed-off-by: Nick Müller <[email protected]> * Added skip_cache override to ExecutionSpec, LaunchPlanSpec and WorkflowExecutionConfig Signed-off-by: Nick Müller <[email protected]> * Added CatalogCacheStatus for skipped cache lookups Signed-off-by: Nick Müller <[email protected]> * Added skip_cache flag to ExecutionRelaunchRequest Signed-off-by: Nick Müller <[email protected]> * Renamed skip_cache flag to overwrite_cache Signed-off-by: Nick Müller <[email protected]> Signed-off-by: Nick Müller <[email protected]> Signed-off-by: Bernhard <[email protected]>
* Added datacatalog endpoint for updating artifacts Existing artifacts can have their associated ArtifactData overwritten Signed-off-by: Nick Müller <[email protected]> * datacatalog.UpdateArtifact returns ArtifactID Signed-off-by: Nick Müller <[email protected]> * Added skip_cache override to ExecutionSpec, LaunchPlanSpec and WorkflowExecutionConfig Signed-off-by: Nick Müller <[email protected]> * Added CatalogCacheStatus for skipped cache lookups Signed-off-by: Nick Müller <[email protected]> * Added skip_cache flag to ExecutionRelaunchRequest Signed-off-by: Nick Müller <[email protected]> * Renamed skip_cache flag to overwrite_cache Signed-off-by: Nick Müller <[email protected]> Signed-off-by: Nick Müller <[email protected]>
TL;DR
This PR prepares datacatalog and flyteadmin endpoints for cache eviction changes, overwriting existing artifacts for a single execution.
Type
Are all requirements met?
Complete description
The new
UpdateArtifact
RPC endpoint for the datacatalog service allows for an existingArtifact
to be updated. At the moment, this update can only contain a (complete) replacement of the associatedArtifactData
.Artifacts can be identified using their ID or tag.
The new
skip_cache
flag in flyteadmin'sExecutionSpec
,LaunchPlanSpec
andWorkflowExecutionConfig
are used to implement the cache eviction override for a single execution.Tracking Issue
flyteorg/flyte#2867
Follow-up issue
NA