David Fernández Calle
09/09/2022, 9:41 AMException: No pod names in job after it started
Stack Trace:
File "/usr/python/__pypackages__/3.9/lib/dagster/_core/execution/plan/utils.py", line 47, in solid_execution_error_boundary
yield
File "/usr/python/__pypackages__/3.9/lib/dagster/_utils/__init__.py", line 430, in iterate_with_context
next_output = next(iterator)
File "/usr/python/__pypackages__/3.9/lib/dagster/_core/execution/plan/compute_generator.py", line 73, in _coerce_solid_compute_fn_to_iterator
result = fn(context, **kwargs) if context_arg_provided else fn(**kwargs)
File "/usr/python/__pypackages__/3.9/lib/dagster/_annotations.py", line 108, in inner
return target(*args, **kwargs)
File "/usr/python/__pypackages__/3.9/lib/dagster_k8s/ops/k8s_job_op.py", line 220, in k8s_job_op
raise Exception("No pod names in job after it started")
Code:
from dagster import job
from dagster_k8s import k8s_job_op
my_k8s_op_1 = k8s_job_op.configured(
{
"image": "myrepo/test:test",
"command": ["run_job.sh"],
"args": [],
"env_vars": ["ENVIRONMENT=stage"],
"resources": {
"requests": {
"memory": "512Mi",
"cpu": "500m"
},
"limits": {
"memory": "2048M",
"cpu": "1000m"
}
},
"pod_spec_config": {"service_account_name": "my-custom-access"},
"service_account_name": "my-dagster-cloud-agent",
},
name="my_test_job",
)
@job()
def my_k8s_job_1():
my_k8s_op_1()
daniel
09/09/2022, 12:28 PM# Allow the Dagster service account to read and write Kubernetes jobs and pods.
rules:
- apiGroups: ["batch"]
resources: ["jobs", "jobs/status"]
verbs: ["*"]
# The empty arg "" corresponds to the core API group
- apiGroups: [""]
resources: ["pods", "pods/log", "pods/status"]
verbs: ["*"]
David Fernández Calle
09/09/2022, 3:09 PM