Michiel
10/09/2024, 1:18 PMfrom prefect import flow
from prefect_kubernetes import run_namespaced_job
from prefect.deployments import run_deployment
@task(name="task1")
def task1():
print("task1")
@task(name="task2")
def task2():
print("task2")
@flow(task_runner=DaskTaskRunner())
def myflow():
task1_result = task1.submit()
task2_result = task2.submit(wait_for=task1_result)
task3_result = run_deployment(<flowname/deploymentname>) # Can I make this deployment run wait for task2 to complete?
Jeff Hale
10/09/2024, 1:51 PMon_completion
hook. Check out the docs here.