Dask plugin for flytekit

Navigation

Verified details

These details have been verified by PyPI
Maintainers
Avatar for flyte-bot from gravatar.com flyte-bot

Unverified details

These details have not been verified by PyPI
Project links
Meta
  • License: Apache Software License (apache2)
  • Author: flyteorg
  • Requires: Python >=3.9
Classifiers

Project description

Flytekit Dask Plugin

Flyte can execute dask jobs natively on a Kubernetes Cluster, which manages the virtual dask cluster's lifecycle (spin-up and tear down). It leverages the open-source Kubernetes Dask Operator and can be enabled without signing up for any service. This is like running a transient (ephemeral) dask cluster - a type of cluster spun up for a specific task and torn down after completion. This helps in making sure that the Python environment is the same on the job-runner (driver), scheduler and the workers.

To install the plugin, run the following command:

pip install flytekitplugins-dask

To configure Dask in the Flyte deployment's backed, follow these directionsernetes/k8s_dask/index.html#step-2-environment-setup)

An usage example can be found in the documentation.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page