fix: ignore errors in GetLog (#15181)

This commit is contained in:
Beto Dealmeida 2021-06-15 16:33:59 -07:00 committed by GitHub
parent d30f3c8149
commit ffdbcbd16e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 1 deletions

View File

@ -331,7 +331,12 @@ class HiveEngineSpec(PrestoEngineSpec):
cursor.cancel()
break
log = cursor.fetch_logs() or ""
try:
log = cursor.fetch_logs() or ""
except Exception: # pylint: disable=broad-except
logger.warning("Call to GetLog() failed")
log = ""
if log:
log_lines = log.splitlines()
progress = cls.progress(log_lines)