compute.delayed
cloud.compute.delayed
Classes
Name | Description |
---|---|
Delayed | Serverless Python function execution as a future. |
DelayedArrayUDF | Serverless Array UDF called with the |
DelayedBase | Base Delayed interface class |
DelayedMultiArrayUDF | Serverless Multi-Array UDF called with the |
DelayedSQL | Serverless SQL query on a registered Array called with the |
Delayed
cloud.compute.delayed.Delayed(
func_exec,*args,
=False,
local=Mode.REALTIME,
mode**kwargs,
)
Serverless Python function execution as a future.
Extends DelayedBase
DelayedArrayUDF
*args, **kwargs) cloud.compute.delayed.DelayedArrayUDF(uri, func_exec,
Serverless Array UDF called with the Delayed API
Extends DelayedBase
DelayedBase
cloud.compute.delayed.DelayedBase(
func,*args,
=None,
name=None,
dag=False,
local_mode=Mode.REALTIME,
mode**kwargs,
)
Base Delayed interface class
Methods
Name | Description |
---|---|
all | Run a list of Delayed object all in parallel |
compute | Starts execution of all Delayed tasks associated with this node. |
visualize | Build and render a tree diagram of the DAG. |
all
all(futures, namespace=None) cloud.compute.delayed.DelayedBase.
Run a list of Delayed object all in parallel
Parameters
Name | Type | Description | Default |
---|---|---|---|
futures | list of Delayed objects to run | required | |
namespace | optional namespace to run all tasks in | None |
Returns
Name | Type | Description |
---|---|---|
list of results in order of futures |
compute
cloud.compute.delayed.DelayedBase.compute(=None,
namespace=None,
name=None,
max_workers )
Starts execution of all Delayed tasks associated with this node.
Parameters
Name | Type | Description | Default |
---|---|---|---|
namespace | Optional[str] | The namespace to execute tasks under, if different than the user’s default. | None |
name | Optional[str] | An optional name to identify the task graph in logs. | None |
Returns
Name | Type | Description |
---|---|---|
Any | results |
visualize
cloud.compute.delayed.DelayedBase.visualize(=True,
notebook=True,
auto_update=False,
force_plotly )
Build and render a tree diagram of the DAG.
Parameters
Name | Type | Description | Default |
---|---|---|---|
notebook | Is the visualization inside a jupyter notebook? If so we’ll use a widget | True |
|
auto_update | Should the diagram be auto updated with each status change | True |
|
force_plotly | Force the use of plotly graphs instead of TileDB Plot Widget | False |
Returns
Name | Type | Description |
---|---|---|
returns plotly figure |
DelayedMultiArrayUDF
*args, **kwargs) cloud.compute.delayed.DelayedMultiArrayUDF(func, array_list,
Serverless Multi-Array UDF called with the Delayed API
Extends DelayedBase
DelayedSQL
*args, **kwargs) cloud.compute.delayed.DelayedSQL(
Serverless SQL query on a registered Array called with the Delayed API
Extends DelayedBase