Patrick Koch
05/11/2022, 1:56 PMAnna Geller
prefect run --name flow_name
and if you have multiple flows with the same name across projects, you need to also specify the project:
prefect run --name flow_name --project xyz
import prefect
from prefect import task, Flow
from prefect.run_configs import KubernetesRun
@task
def concerto_task():
logger = prefect.context.get("logger")
<http://logger.info|logger.info>("Hello world!")
with Flow("my-concerto-flow", run_config = KubernetesRun(job_template_path="deployConcerto.yaml", labels=["9bad561ac917"])) as flow:
concerto_task()
Patrick Koch
05/11/2022, 2:36 PM