Skip to content

Commit 38c1927

Browse files
authored
Update seed file cleanup cron job schedule if needed on startup (#2931)
Fixes #2921
1 parent 4c48d8a commit 38c1927

File tree

1 file changed

+15
-2
lines changed

1 file changed

+15
-2
lines changed

backend/btrixcloud/crawlmanager.py

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -231,16 +231,29 @@ async def ensure_cleanup_seed_file_cron_job_exists(self):
231231
)
232232
if cron_job:
233233
print(
234-
"Cron job to clean up used seed files already exists",
234+
"Cron job to clean up unused seed files already exists",
235235
flush=True,
236236
)
237+
238+
if cron_job.spec.schedule != job_schedule:
239+
cron_job.spec.schedule = job_schedule
240+
241+
await self.batch_api.patch_namespaced_cron_job(
242+
name=cron_job.metadata.name,
243+
namespace=DEFAULT_NAMESPACE,
244+
body=cron_job,
245+
)
246+
print(
247+
f"Cron job to clean up unused seed files updated, schedule: {job_schedule}",
248+
flush=True,
249+
)
237250
return
238251
# pylint: disable=broad-exception-caught
239252
except Exception:
240253
pass
241254

242255
print(
243-
f"Creating cron job to clean up used seed files, schedule: {job_schedule}",
256+
f"Creating cron job to clean up unused seed files, schedule: {job_schedule}",
244257
flush=True,
245258
)
246259

0 commit comments

Comments
 (0)