Skip to content

Commit 3d7cc12

Browse files
committed
Fix bug that finalizer is always configured
1 parent be57783 commit 3d7cc12

2 files changed

Lines changed: 7 additions & 1 deletion

File tree

src/pygeoapi_k8s_manager/manager.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -441,7 +441,7 @@ def create_job_body(p: KubernetesProcessor, job_id: str, data_dict: dict, add_fi
441441
spec=V1JobSpec(
442442
template=V1PodTemplateSpec(
443443
# metadata=V1ObjectMeta(labels=job_pod_spec.extra_labels),
444-
metadata=V1ObjectMeta(finalizers=[format_log_finalizer()] if add_finalizer is not None else None),
444+
metadata=V1ObjectMeta(finalizers=[format_log_finalizer()] if add_finalizer else None),
445445
spec=job_pod_spec.pod_spec,
446446
),
447447
backoff_limit=0,

tests/test_manager.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -553,6 +553,12 @@ def test_create_job_body_sets_required_annotations(job_id, mocked_processor, mim
553553
assert job.metadata.annotations["pygeoapi.io/started"] == job.metadata.annotations["pygeoapi.io/updated"]
554554

555555

556+
def test_create_job_body_does_not_set_finalizer_if_setting_is_false(mocked_processor, job_id):
557+
job = create_job_body(mocked_processor, job_id, {}, False)
558+
559+
assert job.spec.template.metadata.finalizers is None
560+
561+
556562
class KubernetesProcessorForTesting(KubernetesProcessor):
557563
def create_job_pod_spec(self, data, job_name):
558564
return KubernetesProcessor.JobPodSpec(V1PodSpec(containers=[V1Container(name="test-container")]), {})

0 commit comments

Comments
 (0)