George Shishorin
06/22/2022, 12:20 PMfrom prefect import Flow
from prefect.run_configs import DockerRun
from prefect.tasks.docker import (
PullImage,
CreateContainer,
StartContainer,
)
image = PullImage(
repository="georgeshsh/main",
tag="latest")
create_container = CreateContainer(
image_name="georgeshsh/main:latest")
start_container = StartContainer()
with Flow("docker-task-example", run_config=DockerRun(labels=["docker"])) as flow:
container_id = create_container(image)
started = start_container(container_id=container_id)
flow.run()
Kevin Kho
06/22/2022, 1:12 PMprefect agent docker start --volume //var/run/docker.sock:/var/run/docker.sock
George Shishorin
06/22/2022, 2:51 PMKevin Kho
06/22/2022, 2:53 PMGeorge Shishorin
06/22/2022, 2:53 PMKevin Kho
06/22/2022, 2:54 PMGeorge Shishorin
06/22/2022, 2:55 PMdocker.errors.APIError: 400 Client Error for <http+docker://localhost/v1.41/containers/create>: Bad Request ("invalid reference format")
Kevin Kho
06/22/2022, 2:57 PMGeorge Shishorin
06/22/2022, 3:09 PMfrom prefect import Flow
from prefect.run_configs import UniversalRun
from prefect.tasks.docker import (CreateContainer, PullImage, StartContainer)
image = PullImage(
repository="georgeshsh/main",
tag="latest")
create_container = CreateContainer(
image_name="georgeshsh/main:latest")
start_container = StartContainer()
with Flow("docker-task-example",
run_config=UniversalRun(labels=["local"])
) as flow:
container_id = create_container(container_name="test_container")
started = start_container(container_id=container_id)
flow.run()
Kevin Kho
06/22/2022, 3:12 PMGeorge Shishorin
06/22/2022, 3:12 PMKevin Kho
06/22/2022, 3:14 PM