FlowGraph
Applicable Products
|
Product |
Supported |
|---|---|
|
|
√ |
|
|
√ |
|
|
x |
|
|
x |
|
|
x |
Function Description
Defines a DataFlow graph, which consists of the input node FlowData and compute node FlowNode.
Prototype
1
|
FlowGraph(outputs, graph_options={}, name=None, graphpp_builder_async = False) |
Parameters
|
Parameter |
Data Type |
Value Description |
|---|---|---|
|
outputs |
List[FlowOutput] |
All outputs of the FlowGraph output node must be included. For details, see dataflow.FlowOutput. |
|
graph_options |
Dict[str, str] |
Options compiled by FlowGraph, which currently supports the configuration parameters passed by the AddGraph API. For details about options, see Options. The configuration example must be adapted based on Python. |
|
name |
str |
Graph name. The framework automatically ensures that the graph name is unique. If this parameter is not set, names such as FlowGraph, FlowGraph_1, FlowGraph_2, and the like will be automatically generated. |
|
graphpp_builder_async |
bool |
Whether the builder of GraphProcessPoint in FlowGraph is executed asynchronously. The values are as follows:
The default value is False. |
Returns
None is returned in normal scenarios.
The DfException exception is reported in abnormal scenarios. You can obtain error_code and message in DfException to view the error code and error information. For details, see DataFlow Error Codes.
Examples
1 2 |
import dataflow as df graph = df.FlowGraph(...) |
Constraints
None