Thet Naing
02/28/2023, 2:53 PMChristopher Boyd
02/28/2023, 3:03 PMThet Naing
02/28/2023, 4:10 PMChristopher Boyd
02/28/2023, 4:22 PMimage = "<http://gcr.io/|gcr.io/>" + GCP_PROJECT_ID + "/" + environ['PROJECT_NAME']
k8s_job = KubernetesJob(
image=image,
namespace="prefect2",
# name="healthcheck",
name=environ['PROJECT_NAME'],
customizations=customizations,
env=dict(
GCP_PROJECT_ID=GCP_PROJECT_ID,
GCP_RESULTS_BUCKET=GCP_RESULTS_BUCKET,
PREFECT_VERSION=PREFECT_VERSION,
PYTHON_VERSION=PYTHON_VERSION
),
labels={"environment": f'{APP_ENVIRONMENT}'.lower()},
finished_job_ttl=600,
job_watch_timeout_seconds=600,
pod_watch_timeout_seconds=600
)
deployment = Deployment(
name=f"flow-{APP_ENVIRONMENT}",
flow_name="flow-{APP_ENVIRONMENT}",
version=1,
work_queue_name="dev",
infrastructure=k8s_job,
path="/opt/prefect/flows",
parameters=params,
entrypoint="flow.py:main"
)
Thet Naing
02/28/2023, 4:24 PMChristopher Boyd
02/28/2023, 4:25 PMThet Naing
02/28/2023, 4:26 PMPending
state indefinitely. Maybe I'm not waiting long enough, as I've only waited 10 minutes before cancellingNate
02/28/2023, 4:36 PMThet Naing
02/28/2023, 4:47 PMBackoffLimitExceeded
errorChristopher Boyd
02/28/2023, 5:31 PMThet Naing
02/28/2023, 8:43 PM