diff --git a/crawler/api/app.py b/crawler/api/app.py index 8c7db71..688ad13 100644 --- a/crawler/api/app.py +++ b/crawler/api/app.py @@ -94,8 +94,9 @@ async def get_task_status( task_id: str, ) -> dict[str, str]: task_result = listing_tasks.dump_listings_task.AsyncResult(task_id) - result = task_result.result - if type(task_result.result) is TaskRevokedError: + try: + result = json.dumps(task_result.result) + except: result = str(task_result.result) return {