FLOW_NAME = "docker_script"
docker_storage = Docker(
    image_name="test",
    image_tag="latest",
    stored_as_script=True,
    path=f"/app/test3.py",
)


@task(log_stdout=True)
def create_directory():
    text = f"..."
    ROOT_DIR = os.path.dirname(os.path.abspath(__file__))
    local_path = os.path.join(ROOT_DIR, "data")

    Path(local_path).mkdir(parents=True, exist_ok=True)
    return text

with Flow(
    FLOW_NAME,
    storage=docker_storage,
    run_config=DockerRun(
        image="test:latest",
        labels=["docker"],
    ),
) as flow:
    create_dir = create_directory()

if __name__ == "__main__":
    docker_storage.add_flow(flow)
    flow.register(project_name="test_project", build=False)

docker exec