浏览代码

HUE-8744 [task] Catch query already expired on close tentative

Romain 6 年之前
父节点
当前提交
8654d4c83a
共有 1 个文件被更改,包括 5 次插入1 次删除
  1. 5 1
      desktop/libs/notebook/src/notebook/tasks.py

+ 5 - 1
desktop/libs/notebook/src/notebook/tasks.py

@@ -126,7 +126,11 @@ def cancel_async(notebook, snippet, **kwargs):
 @app.task(ignore_result=True)
 def close_statement_async(notebook, snippet, **kwargs):
   request = _get_request(**kwargs)
-  get_api(request, snippet).close_statement(notebook, snippet)
+
+  try:
+    get_api(request, snippet).close_statement(notebook, snippet)
+  except QueryExpired:
+    pass
 
 
 @app.task(ignore_result=True)