Flytekit Memory Machine Cloud Plugin
Flyte Connector plugin to allow executing Flyte tasks using MemVerge Memory Machine Cloud.
To install the plugin, run the following command:
pip install flytekitplugins-mmcloud
To get started with MMCloud, refer to the MMCloud User Guide.
Getting Started
This plugin allows executing PythonFunctionTask using MMCloud without changing any function code.
Resource (cpu and mem) requests and limits, container images, and environment variable specifications are supported.
ImageSpec may be used to define images to run tasks.
Credentials
The following secrets are required to be defined for the connector server:
mmc_address: MMCloud OpCenter addressmmc_username: MMCloud OpCenter usernamemmc_password: MMCloud OpCenter password
Defaults
Compute resources:
- If only requests are specified, there are no limits.
- If only limits are specified, the requests are equal to the limits.
- If neither resource requests nor limits are specified, the default requests used for job submission are
cpu="1"andmem="1Gi", and there are no limits.
Example
example.py workflow example:
import pandas as pd
from flytekit import ImageSpec, Resources, task, workflow
from sklearn.datasets import load_wine
from sklearn.linear_model import LogisticRegression
from flytekitplugins.mmcloud import MMCloudConfig
image_spec = ImageSpec(packages=["scikit-learn"], registry="docker.io/memverge")
@task
def get_data() -> pd.DataFrame:
"""Get the wine dataset."""
return load_wine(as_frame=True).frame
@task(task_config=MMCloudConfig(), container_image=image_spec) # Task will be submitted as MMCloud job
def process_data(data: pd.DataFrame) -> pd.DataFrame:
"""Simplify the task from a 3-class to a binary classification problem."""
return data.assign(target=lambda x: x["target"].where(x["target"] == 0, 1))
@task(
task_config=MMCloudConfig(submit_extra="--migratePolicy [enable=true]"),
requests=Resources(cpu="1", mem="1Gi"),
limits=Resources(cpu="2", mem="4Gi"),
container_image=image_spec,
environment={"KEY": "value"},
)
def train_model(data: pd.DataFrame, hyperparameters: dict) -> LogisticRegression:
"""Train a model on the wine dataset."""
features = data.drop("target", axis="columns")
target = data["target"]
return LogisticRegression(max_iter=3000, **hyperparameters).fit(features, target)
@workflow
def training_workflow(hyperparameters: dict) -> LogisticRegression:
"""Put all of the steps together into a single workflow."""
data = get_data()
processed_data = process_data(data=data)
return train_model(
data=processed_data,
hyperparameters=hyperparameters,
)
Connector Image
Install flytekitplugins-mmcloud in the connector image.
A float binary (obtainable via the OpCenter) is required. Copy it to the connector image PATH.
Sample Dockerfile for building an connector image:
FROM python:3.11-slim-bookworm
WORKDIR /root
ENV PYTHONPATH /root
# flytekit will autoload the connector if package is installed.
RUN pip install flytekitplugins-mmcloud
COPY float /usr/local/bin/float
CMD pyflyte serve connector --port 8000
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file flytekitplugins_mmcloud-1.16.27.tar.gz.
File metadata
- Download URL: flytekitplugins_mmcloud-1.16.27.tar.gz
- Upload date:
- Size: 9.0 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/7.0.0 CPython/3.12.13
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
2f43b92bb6a806a5f60475b37c2dafedfbe14546689364b7f2cbd81d5314b698
|
|
| MD5 |
bad6001763fed1e23953d9ae96b6c6cf
|
|
| BLAKE2b-256 |
cefe5cf4961ad75140c18788c2313a8d9dee46b3714343eff5d7a5a8d092fc18
|
File details
Details for the file flytekitplugins_mmcloud-1.16.27-py3-none-any.whl.
File metadata
- Download URL: flytekitplugins_mmcloud-1.16.27-py3-none-any.whl
- Upload date:
- Size: 8.9 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via:
twine/7.0.0 CPython/3.12.13
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
fbf8dd2d3816b59dbb5bd63edf60b2fddfae6fef227b57e73ff745343c955b61
|
|
| MD5 |
44b9d12c42f3516ebd3e1a2b80aa48cc
|
|
| BLAKE2b-256 |
d05d8fcfc9db44806fec8dc65534c27e80ff4864610d8e94808b7cafb6108fe7
|
