-
Notifications
You must be signed in to change notification settings - Fork 962
Feature: Support spinning a single metaflow step (Rebased) #2506
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
base: master
Are you sure you want to change the base?
Conversation
---------- | ||
blob_iter : Iterator over bytes objects to save | ||
raw : bool, optional | ||
Whether to save the bytes directly or process them, by default False |
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 add default False
for raw
instead of optional
# queries on that same TaskDatastore will be quick (since we already | ||
# have all the metadata) | ||
self._task_metadata_caches = OrderedDict() | ||
# have all the metadata). We keep track of this in a file so it persists |
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 wonder if same should be done for self._store_caches
? which is right now an OrderedDict
# Get the parent steps | ||
steps = [] | ||
for node_name, attributes in graph_info["steps"].items(): | ||
if step_name in attributes["next"]: |
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 wonder if in_funcs
can be used here somehow...
4e80bfa
to
94aa6d6
Compare
51bedca
to
4e8163e
Compare
4e8163e
to
e785d31
Compare
e785d31
to
4d0ad94
Compare
To test
spin
on a new flow you can do the following:Simple case:
Pass in specific pathspec:
Pass in custom artifacts via module:
Skip decorators (including the whitelisted ones):
Use with Runner API:
See the tests for more examples on hot to use this command.