Skip to content

Commit

Permalink
Handle more elastic exceptions (#152)
Browse files Browse the repository at this point in the history
  • Loading branch information
JSCU-CNI authored Nov 27, 2024
1 parent c482853 commit 135a7b8
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions flow/record/adapter/elastic.py
Original file line number Diff line number Diff line change
Expand Up @@ -83,8 +83,8 @@ def __init__(
self.metadata_fields[arg_key[6:]] = arg_val

def excepthook(self, exc: threading.ExceptHookArgs, *args, **kwargs) -> None:
log.error("Exception in thread: %s", exc.exc_value.message)
self.exception = exc.exc_value
log.error("Exception in thread: %s", exc)
self.exception = getattr(exc, "exc_value", exc)
self.event.set()
self.close()

Expand Down

0 comments on commit 135a7b8

Please sign in to comment.