Buğra Gedik
05/17/2024, 5:55 PMKetan (kumare3)
Ketan (kumare3)
Ketan (kumare3)
Ketan (kumare3)
MEM = "10Gi"
if os.getenv("HIGH_MEM", False):
MEM = "100Gi"
@task(resources=Resources(mem=MEM))
def foo():
...
Ketan (kumare3)
Ketan (kumare3)
pyflyte run
this will auto-register a new versionBuğra Gedik
05/17/2024, 6:42 PMYi Chiu
05/17/2024, 6:53 PMflytectl update task-resource-attribute --attrFile tra.yaml
# tra.yaml
domain: development
project: flytesnacks
workflow: core.control_flow.merge_sort.merge_sort
defaults:
cpu: "1"
memory: "150Mi"
limits:
cpu: "2"
memory: "450Mi"