So I have this deployment in Prefect 2.0:

DeploymentSpec(
    flow_location=str((FLOW_DIR / "salesforce.py").absolute()),
    flow_name="elt-salesforce",
    name="sf-production-elt-job",
    schedule=IntervalSchedule(interval=timedelta(hours=1)),
    tags=["pipeline"],
    flow_runner=DockerFlowRunner(image=f"{IMAGE_REPO}/{DBT_IMAGE}:{TAG}", stream_output=True)
)

And it took awhile to come to me as a requirement but I essentially have 2 steps. Step one requires docker image A to do some data pipeline stuff, step 2 needs my custom dbt docker image B to do some transform AFTER step 1. So these two dependent tasks constitute one flow with each step on independent docker images. A flow runner is configured at a deployment level but I dont see a way to configure it at the task or subflow level. Definitely a key req in current state. Please help!

Will test this tomorrow but I think it should work with Client.create_flow_run_from_deployment

This is a roadmap item, but not one that we expect to solve until later this year.

@Zanie made my day. Sometimes it's the simple things, y'know. I wasn't thinking outside the box, or inside. Or wherever. Just in the Prefect box. docker-py is a perfect shim here.

It's actually a good analogy because Prefect is more about the arrows than the boxes - check this blog post