Dear < CL09KU1K7|> A few weeks before I ve published a blog Prefect Community #ask-community

Dear <#CL09KU1K7|>! A few weeks before I've publi...

Patrick Koch

05/11/2022, 1:56 PM

Dear #CL09KU1K7! A few weeks before I've published a blog post here, https://www.patrickkoch.dev/posts/post_15/ in which I've run Prefect Flows as Kubernetes Jobs. For that, I've used a Windows Container Workload. I've started as newbie with regard to Prefect, currently I've had to try several other use cases - but with regard to those one mentioned in my blog post, I've recognized some behaviour which I didn't expect: After triggering the Prefect Flow, the Workload at the Kubernetes Cluster is deployed successfully, but sometimes I get following warning:

Anna Geller

05/11/2022, 2:05 PM

Good question! Usually, such warnings and Lazarus processes are triggered when there is some issue with the execution layer. You don't need to attach the label when triggering a flow run via CLI when you attach it already on your run config, this should be enough:

Copy code

prefect run --name flow_name

and if you have multiple flows with the same name across projects, you need to also specify the project:

Copy code

prefect run --name flow_name --project xyz

👀 1

Anna Geller

05/11/2022, 2:06 PM

moving code block:

Copy code

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

@Anna Geller thank you for your quick answer (as always) 🙂 I'll try your suggestions 🙂

👍 1

6 Views

Open in Slack

Previous Next