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
feat(core): make rerun work with new storage #2319
Conversation
b7d0c43
to
b19e016
Compare
def _get_activities(paths: List[str], sources: List[str], activity_gateway: IActivityGateway): | ||
all_activities = defaultdict(set) | ||
|
||
def include_newest_activity(activity): |
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.
This is a duplicate of the one used in update
, would make sense to unify them
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.
I've added a more general utility function and used it here. There is still a duplicated line but I believe it's more readable and re-usable this way.
7279445
to
f57ccb2
Compare
b27701c
to
2aa8abd
Compare
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.
Thank you!
2aa8abd
to
79f8757
Compare
Description
Reimplementation of the
renku run <paths>
using the new persistent layer. Support--from
flag to start execution from a specific path. Returns 1 if no workflow is re-executed.Followup story: #2323
Fixes #2258