From 1a2a5918e749b7d47c2f7228158203cac9ce57e0 Mon Sep 17 00:00:00 2001 From: khorshuheng Date: Wed, 29 Jun 2022 14:58:35 +0800 Subject: [PATCH] Ignore cancelled job Signed-off-by: khorshuheng --- python/feast_spark/job_service.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/python/feast_spark/job_service.py b/python/feast_spark/job_service.py index 3ba6ba4..746e68f 100644 --- a/python/feast_spark/job_service.py +++ b/python/feast_spark/job_service.py @@ -489,7 +489,12 @@ def ensure_stream_ingestion_jobs(client: Client, all_projects: bool): for job_hash in job_hashes_to_cancel: job = jobs_by_hash[job_hash] - if job.get_status() != SparkJobStatus.IN_PROGRESS: + job_status = None + try: + job_status = job.get_status() + except JobNotFoundException: + pass + if job_status != SparkJobStatus.IN_PROGRESS: logger.warning( f"Can't cancel job with job_hash={job_hash} job_id={job.get_id()} status={job.get_status()}" )