From cfdf4513c212ca4e597d0746b9bf387bca31f4b5 Mon Sep 17 00:00:00 2001 From: Jayden Date: Sun, 21 Jul 2024 21:49:55 -0500 Subject: [PATCH] fix: issue with updating jobs --- api/backend/worker/job_worker.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/api/backend/worker/job_worker.py b/api/backend/worker/job_worker.py index 6ee160d..957b1fc 100644 --- a/api/backend/worker/job_worker.py +++ b/api/backend/worker/job_worker.py @@ -17,7 +17,7 @@ async def process_job(): if job: LOG.info(f"Beginning processing job: {job}.") try: - _ = await update_job(job["id"], field="status", value="Scraping") + _ = await update_job([job["id"]], field="status", value="Scraping") scraped = await scrape( job["url"], [Element(**j) for j in job["elements"]], @@ -28,12 +28,12 @@ async def process_job(): f"Scraped result for url: {job['url']}, with elements: {job['elements']}\n{scraped}" ) _ = await update_job( - job["id"], field="result", value=jsonable_encoder(scraped) + [job["id"]], field="result", value=jsonable_encoder(scraped) ) _ = await update_job(job["id"], field="status", value="Completed") except Exception as e: - _ = await update_job(job["id"], field="status", value="Failed") - _ = await update_job(job["id"], field="result", value=e) + _ = await update_job([job["id"]], field="status", value="Failed") + _ = await update_job([job["id"]], field="result", value=e) LOG.error(f"Exception as occured: {e}\n{traceback.print_exc()}")