nice-judge-43061
09/15/2022, 9:36 AMglamorous-carpet-83516
09/15/2022, 9:39 AMglamorous-carpet-83516
09/15/2022, 9:41 AMnice-judge-43061
09/15/2022, 9:46 AMnice-judge-43061
09/15/2022, 9:47 AMglamorous-carpet-83516
09/15/2022, 9:48 AMglamorous-carpet-83516
09/15/2022, 9:49 AMpyflyte --config ~/.flyte/config-remote.yaml register example_union1.py (or a folder example/)
nice-judge-43061
09/15/2022, 9:52 AMnice-judge-43061
09/15/2022, 9:52 AMglamorous-carpet-83516
09/15/2022, 9:53 AMnice-judge-43061
09/15/2022, 9:59 AMnice-judge-43061
09/15/2022, 10:00 AMnice-judge-43061
09/15/2022, 10:11 AMnice-judge-43061
09/15/2022, 10:12 AMglamorous-carpet-83516
09/15/2022, 10:13 AMnice-judge-43061
09/15/2022, 11:24 AMglamorous-carpet-83516
09/15/2022, 11:26 AMnice-judge-43061
09/15/2022, 11:31 AMglamorous-carpet-83516
09/15/2022, 11:37 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
nice-judge-43061
09/15/2022, 11:46 AMglamorous-carpet-83516
09/15/2022, 11:52 AMnice-judge-43061
09/15/2022, 11:53 AMnice-judge-43061
09/15/2022, 11:54 AMglamorous-carpet-83516
09/15/2022, 11:54 AMnice-judge-43061
09/15/2022, 11:55 AMnice-judge-43061
09/15/2022, 12:15 PMglamorous-carpet-83516
09/15/2022, 12:17 PMnice-judge-43061
09/15/2022, 12:19 PMnice-judge-43061
09/15/2022, 1:18 PMtall-lock-23197
nice-judge-43061
09/16/2022, 11:39 AMtall-lock-23197
nice-judge-43061
09/16/2022, 3:21 PMnice-judge-43061
09/16/2022, 3:22 PMtall-lock-23197
nice-judge-43061
09/16/2022, 4:11 PMglamorous-carpet-83516
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()
glamorous-carpet-83516
09/16/2022, 4:25 PMnice-judge-43061
09/16/2022, 4:34 PMnice-judge-43061
09/19/2022, 8:26 AMfrom 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))
@tall-lock-23197
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.tall-lock-23197
glamorous-carpet-83516
09/20/2022, 5:18 AMtall-lock-23197
tall-lock-23197
tall-lock-23197
glamorous-carpet-83516
09/20/2022, 5:44 AMAlso, this isn’t working when run locally, right?yes, and running remotely doesn’t work as well
thankful-minister-83577
thankful-minister-83577
thankful-minister-83577
high-accountant-32689
09/20/2022, 4:58 PMhigh-accountant-32689
09/20/2022, 5:25 PM