# Flytekit
[![PyPI version fury.io](https://badge.fury.io/py/flytekit.svg)](https://pypi.python.org/pypi/flytekit/)
[![PyPI download day](https://img.shields.io/pypi/dd/flytekit.svg)](https://pypi.python.org/pypi/flytekit/)
[![PyPI download month](https://img.shields.io/pypi/dm/flytekit.svg)](https://pypi.python.org/pypi/flytekit/)
[![PyPI format](https://img.shields.io/pypi/format/flytekit.svg)](https://pypi.python.org/pypi/flytekit/)
[![PyPI implementation](https://img.shields.io/pypi/implementation/flytekit.svg)](https://pypi.python.org/pypi/flytekit/)
![Codecov](https://img.shields.io/codecov/c/github/lyft/flytekit?style=plastic)
Python Library for easily authoring, testing, deploying, and interacting with Flyte tasks, workflows, and launch plans. To understand more about flyte refer to,
- [Flyte homepage](https://flyte.org)
- [Flyte master repository](https://github.com/lyft/flyte)
## Installation
Flytekit is designed for minimal footprint, and thus some features must be installed as extras.
### Base Installation
This is the lightest-weight SDK install. This installation includes everything you need to interact with Flyte.
Modules include:
1. The full Flyte IDL and an additional model layer for easier extension of the data model.
2. gRPC client for communicating with the platform.
3. Implementations for authoring and extending all Flyte entities (including tasks, workflows, and launch plans).
Tools include:
1. flyte-cli (Command-Line Interface for Interacting with the Flyte Platform)
2. pyflyte (Command-Line tool for easing the registration of Flyte entities)
```bash
pip install flytekit
```
### Plugin Installation
#### Spark
If `@spark_task` is to be used, one should install the `spark` plugin.
```bash
pip install "flytekit[spark]" for Spark 2.4.x
pip install "flytekit[spark3]" for Spark 3.x
```
#### Schema
If `Types.Schema()` is to be used for computations involving large dataframes, one should install the `schema` extension.
```bash
pip install "flytekit[schema]"
```
#### Sidecar
If `@sidecar_task` is to be used, one should install the `sidecar` plugin.
```bash
pip install "flytekit[sidecar]"
```
### Pytorch
If `@pytorch_task` is to be used, one should install the `pytorch` plugin.
```bash
pip install "flytekit[pytorch]"
```
### Full Installation
To install all or multiple available plugins, one can specify them individually:
```bash
pip install "flytekit[sidecar,spark,schema]"
```
Or install them with the `all` directive. `all` defaults to Spark 2.4.x currently.
```bash
pip install "flytekit[all]"
```
## Testing
Flytekit is Python 2.7+ compatible, so when feasible, it is recommended to test with both Python 2 and 3.
### Unit Testing
#### Setup (Do Once)
```bash
virtualenv ~/.virtualenvs/flytekit
source ~/.virtualenvs/flytekit/bin/activate
python -m pip install -r requirements.txt
python -m pip install -U ".[all]"
```
#### Execute
```bash
source ~/.virtualenvs/flytekit/bin/activate
python -m pytest tests/flytekit/unit
shellcheck **/*.sh
```
没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
资源分类:Python库 所属语言:Python 资源全名:flytekit-0.11.3.tar.gz 资源来源:官方 安装方法:https://lanzao.blog.csdn.net/article/details/101784059
资源推荐
资源详情
资源评论
收起资源包目录
Python库 | flytekit-0.11.3.tar.gz (183个子文件)
setup.cfg 339B
flytekit_venv 221B
README.md 3KB
PKG-INFO 5KB
PKG-INFO 5KB
main.py 70KB
tasks.py 52KB
schema.py 43KB
friendly.py 43KB
task.py 30KB
raw.py 28KB
engine.py 25KB
workflow.py 25KB
literals.py 23KB
blobs.py 20KB
sdk_runnable.py 20KB
workflow.py 20KB
tasks.py 18KB
primitives.py 18KB
nodes.py 16KB
launch_plan.py 16KB
blobs.py 16KB
task.py 15KB
types.py 15KB
sdk_dynamic.py 15KB
execution.py 14KB
engine.py 14KB
common.py 13KB
launch_plan.py 12KB
common.py 11KB
hive_task.py 11KB
auth.py 10KB
training_job.py 10KB
launch_plan.py 10KB
common.py 10KB
raw_container.py 9KB
serialize.py 9KB
types.py 8KB
scopes.py 8KB
flyte.py 8KB
hpo_job.py 8KB
interface.py 7KB
utils.py 7KB
registerable.py 7KB
condition.py 7KB
presto_task.py 7KB
schema.py 7KB
execution.py 7KB
s3proxy.py 7KB
component_nodes.py 7KB
interface.py 6KB
task.py 6KB
matchable_resource.py 6KB
identifier.py 6KB
identifier.py 6KB
compiler.py 6KB
parameter_ranges.py 6KB
spark_task.py 6KB
data_proxy.py 6KB
schedules.py 6KB
promise.py 6KB
sidecar_task.py 5KB
module_loader.py 5KB
workflow_execution.py 5KB
task_execution.py 5KB
generic_spark_task.py 5KB
workflow.py 5KB
containers.py 5KB
helpers.py 5KB
training_job_task.py 5KB
impl.py 5KB
client.py 5KB
proto.py 5KB
entrypoint.py 5KB
register.py 5KB
pyflyte.py 4KB
qubole.py 4KB
executions.py 4KB
gcs_proxy.py 4KB
notifications.py 4KB
hpo_job_task.py 4KB
launchable.py 4KB
node_execution.py 4KB
base_sdk_types.py 4KB
filters.py 4KB
dynamic_job.py 4KB
sdk.py 4KB
workflow.py 4KB
test_utils.py 4KB
helpers.py 4KB
base_sensor.py 3KB
internal.py 3KB
schedule.py 3KB
lazy_loader.py 3KB
creds.py 3KB
helpers.py 3KB
artifact.py 3KB
named_entity.py 3KB
array_job.py 3KB
user.py 3KB
共 183 条
- 1
- 2
资源评论
挣扎的蓝藻
- 粉丝: 14w+
- 资源: 15万+
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功