KS Tarun
09/15/2022, 9:36 AMKevin Su
09/15/2022, 9:39 AMKS Tarun
09/15/2022, 9:46 AMKevin Su
09/15/2022, 9:48 AMpyflyte --config ~/.flyte/config-remote.yaml register example_union1.py (or a folder example/)
KS Tarun
09/15/2022, 9:52 AMKevin Su
09/15/2022, 9:53 AMKS Tarun
09/15/2022, 9:59 AMKevin Su
09/15/2022, 10:13 AM$ kubectl edit cm flyte-propeller-config
k8s.yaml: |
plugins:
k8s:
default-cpus: 600m
default-env-vars:
- FLYTE_AWS_ENDPOINT: <http://minio.flyte.svc.cluster.local:9000>
- FLYTE_AWS_ACCESS_KEY_ID: minio
- FLYTE_AWS_SECRET_ACCESS_KEY: miniostorage
default-memory: 600Mi
KS Tarun
09/15/2022, 11:46 AMKevin Su
09/15/2022, 11:52 AMKS Tarun
09/15/2022, 11:53 AMKevin Su
09/15/2022, 11:54 AMKS Tarun
09/15/2022, 11:55 AMKevin Su
09/15/2022, 12:17 PMKS Tarun
09/15/2022, 12:19 PMSamhita Alla
KS Tarun
09/16/2022, 11:39 AMSamhita Alla
KS Tarun
09/16/2022, 3:21 PMSamhita Alla
KS Tarun
09/16/2022, 4:11 PMKevin Su
09/16/2022, 4:24 PMfrom flytekit import task, workflow
@task(cache=True, cache_version="1.0")
def t1() -> int:
return 2
@workflow
def wf() -> int:
return t1()
if __name__ == "__main__":
wf()
KS Tarun
09/16/2022, 4:34 PMfrom flytekit import Resources,task
from flytekit import workflow
@task(cache_version="1.0", cache=True, limits=Resources(mem="500Mi"))
def add(a:int,b:int) -> int:
return a+b
@task(cache_version="1.0", cache=True, limits=Resources(mem="500Mi"))
def multiply(x:int,y:int) -> int:
return x*y
@workflow
def output(l:int,m:int,n:int) -> int:
return multiply(x=n,y=add(a=l,b=m))
@Samhita Alla
I'm registering this workflow.
In this code, for version 1.0, I'm multiplying x & y. And later in the next version I'm adding x & y. The output when I run the 1.1 version is same as 1.0.Samhita Alla
Kevin Su
09/20/2022, 5:18 AMSamhita Alla
Kevin Su
09/20/2022, 5:44 AMAlso, this isn’t working when run locally, right?yes, and running remotely doesn’t work as well
Yee
Eduardo Apolinario (eapolinario)
09/20/2022, 4:58 PM