-
Notifications
You must be signed in to change notification settings - Fork 5.5k
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
[workflow] Deprecate workflow.create #26106
Conversation
e723c89
to
b87ba3d
Compare
|
||
Dynamic workflows | ||
----------------- | ||
|
||
Additional tasks can be dynamically created and inserted into the workflow DAG during execution. | ||
|
||
This is achieved by returning a continuation of a DAG. | ||
A continuation is something returned by a function and executed after it returns. | ||
|
||
In our context, a continuation is basically a tail function call returned by a function. For example: |
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.
Maybe also adds a sentence about how the continuation behaves in ray core engine.
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.
hmmm, I do not want to mention how a DAG is executed by default in Ray core engine. I feel this complicates the topic.
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.
LG. Some small comments.
|
The failed CI test seems unrelated. I'll merge the PR. |
* master: (104 commits) [Serve] Java Client API and End to End Tests (ray-project#22726) [Docs] Small fix to AIR examples descriptions (ray-project#26227) [Deployment Graph] Move `Deployment` creation outside to build function (ray-project#26129) [K8s][Ray Operator] Ignore resource requests when detected container resources. (ray-project#26234) Revert "[Core] Add retry exception allowlist for user-defined filteri… (ray-project#26289) [ci] pin gpustat (ray-project#26311) [tune] fix `set_tune_experiment` (ray-project#26298) Revert "Revert "[AIR][Serve] Rename ModelWrapperDeployment -> PredictorDeployment"" (ray-project#26231) [Release] Use nightly base images for release tests (ray-project#25373) Revert "[Core] fix gRPC handlers' unlimited active calls configuration (ray-project#25626)" (ray-project#26202) [RLlib] Some Docs fixes (2). (ray-project#26265) [C++ worker] Refine worker context and more (ray-project#26281) Fix file_system_monitor.cc message (ray-project#26143) [Java] Make Java test more stable (ray-project#26282) [air] Do not warn of `checkpoint_dir` if it's coming from us (base_trainer). (ray-project#26259) [Datasets] Support drop_columns API (ray-project#26200) [Datasets] Fix max number of actors for default actor pool strategy (ray-project#26266) [ci] Stop syncer staging tests (ray-project#26273) [core][gcs] Add storage namespace to redis storage in GCS. (ray-project#25994) [workflow] Deprecate workflow.create (ray-project#26106) ...
Signed-off-by: Edward Oakes <[email protected]>
Signed-off-by: klwuibm <[email protected]>
Signed-off-by: Frank Luan <[email protected]>
Why are these changes needed?
After deprecating
Workflow
class in #25618 ,workflow.create
becomes a redundant API and should be deprecated.We update examples and docs correspondingly.
Related issue number
Checks
scripts/format.sh
to lint the changes in this PR.