ash
06/14/2021, 9:56 PM@task
def say_hello():
print("hello world !!!")
with Flow("hello world") as flow:
say_hello()
flow.storage = Docker(registry_url = "", image name = "hello world flow")
flow.register("demo")
Can someone please explain to me
1.) Why we used container registry for storing a flow and what difference would it make compared to other script based storage like github.
2.) When we execute a flow whose server is present on K8 but no executer is defined like in above snippet, where would the flow be executed on local machine or on a pod on the cluster.Mariia Kerimova
06/14/2021, 10:09 PMKevin Kho
06/14/2021, 10:10 PMash
06/14/2021, 10:16 PMKevin Kho
06/14/2021, 10:18 PMash
06/14/2021, 10:20 PMKevin Kho
06/14/2021, 10:22 PMRunConfig
will let you determine the resources for that flow like
flow.run_config = KubernetesRun(cpu_request=2, memory_request="2Gi")
ash
06/14/2021, 10:24 PMRunConfig objects define where and how a flow run should be executed. Each RunConfig type has a corresponding Prefect Agent (i.e. LocalRun pairs with a Local Agent, DockerRun pairs with a Docker Agent, ...)
Kevin Kho
06/14/2021, 10:29 PMash
06/14/2021, 10:33 PMhelm would be separate from these concepts as it's for installation
Kevin Kho
06/14/2021, 10:34 PMash
06/14/2021, 10:35 PMKevin Kho
06/14/2021, 10:37 PMash
06/14/2021, 10:39 PMKevin Kho
06/14/2021, 10:40 PMash
06/14/2021, 10:41 PM