Lytekit

Latest version: v0.15.28

Safety actively analyzes 714860 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 46 of 73

0.21.0b2

0.21.0b1

https://github.com/flyteorg/flytekit/pull/543

0.21.0b0

Reads auth from flytekit config file during registration

0.20.2

https://github.com/flyteorg/flytekit/pull/630

0.20.1

Two principal PRs:
https://github.com/flyteorg/flytekit/pull/533
https://github.com/flyteorg/flytekit/pull/522

Plus some other minor documentation nits and requirements updates.

0.20

Core Authoring
* [Enum Type support](https://github.com/flyteorg/flytekit/pull/509). Flyteconsole update coming soon.
python
from enum import Enum

class Color(Enum):
RED = "red"
BLUE = "blue"
GREEN = "green"

task
def foo(c: Color) -> str:
return c.value

* Support for Schema inference for Structured types - ``dataclass`` - usable in flytectl, Flyteconsole update coming soon
* Use map with pod tasks (https://github.com/flyteorg/flytekit/pull/510)
* Max parallelism added to LaunchPlans: (https://github.com/flyteorg/flytekit/pull/510)
- Max parallelism allows to limit number of nodes to be executed concurrently within a workflow
python
max_parallelism_lp1 = launch_plan.LaunchPlan.get_or_create(
workflow=wf,
name="name",
max_parallelism=max_parallelism,
)

* Node resource override (https://github.com/flyteorg/flytekit/pull/523)
Example shows you can override resources when you create a node in map task
python
workflow
def my_wf(a: typing.List[str]) -> typing.List[str]:
mappy = map_task(t1)
map_node = create_node(mappy, a=a).with_overrides(
requests=Resources(cpu="1", mem="100"), limits=Resources(cpu="2", mem="200")
)
return map_node.o0

for regular task
python
workflow
def my_wf(a: str) -> str:
return t1(a=a).with_overrides(
requests=Resources(cpu="1", mem="100"), limits=Resources(cpu="2", mem="200")
)

* new package -> register Flow (https://github.com/flyteorg/flytekit/pull/526). This flow is the preferred flow going forward. Also powers getting started etc

pyflyte --pkgs myapp.workflows package --image myapp:03eccc1cf101adbd8c4734dba865d3fdeb720aa7 -f --fast

* Much better documentation

Control Plane
* control_plane -> remote. This will not change now. moving in beta

Plugins
* AWS Athena plugin: (https://github.com/flyteorg/flytekit/pull/504)

athena_task = AthenaTask(
name="flytekit.demo.athena_task.query",
inputs=kwtypes(ds=str),
task_config=AthenaConfig(database="mnist", catalog="my_catalog", workgroup="my_wg"),
query_template="""
insert overwrite directory '{{ .rawOutputDataPrefix }}' stored as parquet
select *
from blah
where ds = '{{ .Inputs.ds }}'
""",
the schema literal's backend uri will be equal to the value of .raw_output_data
output_schema_type=FlyteSchema,
)


Smaller Fixes
* Destination Dir is automatically filled in for fast register. Improves portability

Page 46 of 73

Links

Releases

Has known vulnerabilities

© 2025 Safety CLI Cybersecurity Inc. All Rights Reserved.