Christian Nuss
03/03/2022, 4:51 PMKubernetesRun
defininig the job_template
as a dict?Kevin Kho
03/03/2022, 5:10 PMjob
is a dict thereChristian Nuss
03/03/2022, 5:12 PMKevin Kho
03/03/2022, 5:16 PMChristian Nuss
03/03/2022, 5:46 PMreturn KubernetesRun(
labels=labels,
env=app_settings_dict,
image=app_settings.PREFECT_WORKFLOWS_CONTAINER,
image_pull_policy="IfNotPresent",
job_template={
"apiVersion": "batch/v1",
"kind": "Job",
"spec": {
"template": {
"spec": {
"labels": {
"foo": "test123"
},
"containers": [
{
"name": "flow"
}
]
}
}
}
}
)
Kevin Kho
03/03/2022, 5:49 PMChristian Nuss
03/03/2022, 8:16 PMKevin Kho
03/03/2022, 8:21 PMChristian Nuss
03/03/2022, 8:42 PMreturn KubernetesRun(
labels=labels,
env=app_settings_dict,
image=app_settings.PREFECT_WORKFLOWS_CONTAINER,
image_pull_policy="IfNotPresent",
job_template={
"apiVersion": "batch/v1",
"kind": "Job",
"spec": {
"template": {
"metadata": {
"labels": {
"foo": "test123"
}
},
"spec": {
"containers": [
{
"name": "flow"
}
]
}
}
}
}
)
Kevin Kho
03/03/2022, 9:03 PMChristian Nuss
03/03/2022, 9:21 PMKevin Kho
03/03/2022, 9:25 PM