Browse Source

fix celery job not closed issue (#19268)

tags/1.4.2
Jyong 5 months ago
parent
commit
fb12a3033d
No account linked to committer's email address

+ 1
- 1
api/tasks/document_indexing_sync_task.py View File

except DocumentIsPausedError as ex: except DocumentIsPausedError as ex:
logging.info(click.style(str(ex), fg="yellow")) logging.info(click.style(str(ex), fg="yellow"))
except Exception: except Exception:
pass
logging.exception("document_indexing_sync_task failed, document_id: {}".format(document_id))

+ 1
- 1
api/tasks/document_indexing_task.py View File

except DocumentIsPausedError as ex: except DocumentIsPausedError as ex:
logging.info(click.style(str(ex), fg="yellow")) logging.info(click.style(str(ex), fg="yellow"))
except Exception: except Exception:
pass
logging.exception("Document indexing task failed, dataset_id: {}".format(dataset_id))
finally: finally:
db.session.close() db.session.close()

+ 1
- 1
api/tasks/document_indexing_update_task.py View File

except DocumentIsPausedError as ex: except DocumentIsPausedError as ex:
logging.info(click.style(str(ex), fg="yellow")) logging.info(click.style(str(ex), fg="yellow"))
except Exception: except Exception:
pass
logging.exception("document_indexing_update_task failed, document_id: {}".format(document_id))
finally: finally:
db.session.close() db.session.close()

+ 1
- 1
api/tasks/duplicate_document_indexing_task.py View File

except DocumentIsPausedError as ex: except DocumentIsPausedError as ex:
logging.info(click.style(str(ex), fg="yellow")) logging.info(click.style(str(ex), fg="yellow"))
except Exception: except Exception:
pass
logging.exception("duplicate_document_indexing_task failed, dataset_id: {}".format(dataset_id))
finally: finally:
db.session.close() db.session.close()

+ 1
- 1
api/tasks/recover_document_indexing_task.py View File

except DocumentIsPausedError as ex: except DocumentIsPausedError as ex:
logging.info(click.style(str(ex), fg="yellow")) logging.info(click.style(str(ex), fg="yellow"))
except Exception: except Exception:
pass
logging.exception("recover_document_indexing_task failed, document_id: {}".format(document_id))
finally: finally:
db.session.close() db.session.close()

+ 1
- 1
api/tasks/retry_document_indexing_task.py View File

db.session.commit() db.session.commit()
logging.info(click.style(str(ex), fg="yellow")) logging.info(click.style(str(ex), fg="yellow"))
redis_client.delete(retry_indexing_cache_key) redis_client.delete(retry_indexing_cache_key)
pass
logging.exception("retry_document_indexing_task failed, document_id: {}".format(document_id))
finally: finally:
db.session.close() db.session.close()
end_at = time.perf_counter() end_at = time.perf_counter()

+ 1
- 1
api/tasks/sync_website_document_indexing_task.py View File

db.session.commit() db.session.commit()
logging.info(click.style(str(ex), fg="yellow")) logging.info(click.style(str(ex), fg="yellow"))
redis_client.delete(sync_indexing_cache_key) redis_client.delete(sync_indexing_cache_key)
pass
logging.exception("sync_website_document_indexing_task failed, document_id: {}".format(document_id))
end_at = time.perf_counter() end_at = time.perf_counter()
logging.info(click.style("Sync document: {} latency: {}".format(document_id, end_at - start_at), fg="green")) logging.info(click.style("Sync document: {} latency: {}".format(document_id, end_at - start_at), fg="green"))

Loading…
Cancel
Save