if __name__ == "__main__":
    deployment = build_deployment_from_flow(
        flow=log,
        name="run",
        work_queue_name="work",
        path=str(Path().resolve()),
        entrypoint="deployments/log.py:log",
    )
    deployment.apply()

def build_deployment_from_flow(
    flow: str, name: str, work_queue_name: str, path: str, entrypoint: str
):
    args = {
        "flow": flow,
        "name": name,
        "work_queue_name": work_queue_name,
    }

    if os.getenv("DEPLOY_ENV") == "prod":
        print("using GCS Block")
        return Deployment.build_from_flow(
            **args,
            path=path + "/deployments",
            storage=GCS.load("flows"),
            entrypoint=entrypoint.split("/")[-1]
        )

    return Deployment.build_from_flow(
        **args,
        **{
            "path": path,
            "entrypoint": entrypoint,
        }
    )