1.16.32
flytekitplugins.mmcloud.connector
Directory
Classes
| Class | Description |
|---|---|
MMCloudConnector |
|
MMCloudMetadata |
flytekitplugins.mmcloud.connector.MMCloudConnector
Parameters
def MMCloudConnector()Properties
| Property | Type | Description |
|---|---|---|
metadata_type |
flytekit.extend.backend.base_connector.ResourceMeta |
|
task_category |
flytekit.extend.backend.base_connector.TaskCategory |
task category that the connector supports |
Methods
| Method | Description |
|---|---|
async_login() |
Log in to Memory Machine Cloud OpCenter. |
create() |
Submit a Flyte task as MMCloud job to the OpCenter, and return the job UID for the task. |
delete() |
Delete the task. |
get() |
Return the status of the task, and return the outputs on success. |
get_logs() |
Return the metrics for the task. |
get_metrics() |
Return the metrics for the task. |
async_login()
def async_login()Log in to Memory Machine Cloud OpCenter.
create()
def create(
task_template: flytekit.models.task.TaskTemplate,
inputs: typing.Optional[flytekit.models.literals.LiteralMap] = None,
**kwargs,
) -> flytekitplugins.mmcloud.connector.MMCloudMetadataSubmit a Flyte task as MMCloud job to the OpCenter, and return the job UID for the task.
| Parameter | Type | Description |
|---|---|---|
task_template |
flytekit.models.task.TaskTemplate |
|
inputs |
typing.Optional[flytekit.models.literals.LiteralMap] |
|
**kwargs |
delete()
def delete(
resource_meta: flytekitplugins.mmcloud.connector.MMCloudMetadata,
**kwargs,
)Delete the task. This call should be idempotent.
| Parameter | Type | Description |
|---|---|---|
resource_meta |
flytekitplugins.mmcloud.connector.MMCloudMetadata |
|
**kwargs |
get()
def get(
resource_meta: flytekitplugins.mmcloud.connector.MMCloudMetadata,
**kwargs,
) -> flytekit.extend.backend.base_connector.ResourceReturn the status of the task, and return the outputs on success.
| Parameter | Type | Description |
|---|---|---|
resource_meta |
flytekitplugins.mmcloud.connector.MMCloudMetadata |
|
**kwargs |
get_logs()
def get_logs(
resource_meta: flytekit.extend.backend.base_connector.ResourceMeta,
**kwargs,
) -> flyteidl.admin.agent_pb2.GetTaskLogsResponseReturn the metrics for the task.
| Parameter | Type | Description |
|---|---|---|
resource_meta |
flytekit.extend.backend.base_connector.ResourceMeta |
|
**kwargs |
get_metrics()
def get_metrics(
resource_meta: flytekit.extend.backend.base_connector.ResourceMeta,
**kwargs,
) -> flyteidl.admin.agent_pb2.GetTaskMetricsResponseReturn the metrics for the task.
| Parameter | Type | Description |
|---|---|---|
resource_meta |
flytekit.extend.backend.base_connector.ResourceMeta |
|
**kwargs |
flytekitplugins.mmcloud.connector.MMCloudMetadata
Parameters
class MMCloudMetadata(
job_id: str,
)| Parameter | Type | Description |
|---|---|---|
job_id |
str |
Methods
| Method | Description |
|---|---|
decode() |
Decode the resource meta from bytes. |
encode() |
Encode the resource meta to bytes. |
decode()
def decode(
data: bytes,
) -> ResourceMetaDecode the resource meta from bytes.
| Parameter | Type | Description |
|---|---|---|
data |
bytes |
encode()
def encode()Encode the resource meta to bytes.