feat: Add ExecutionEvent.is_terminal attribute that indicates wheth…

…er an event is the last one in the stream

docs/changelog.rst

@@ -4,6 +4,10 @@ Changelog
 `Unreleased`_ - TBD
 -------------------
 
+**Added**
+
+- ``ExecutionEvent.is_terminal`` attribute that indicates whether an event is the last one in the stream.
+
 **Fixed**
 
 - When ``EventStream.stop`` is called, the next event always is the last one.

src/schemathesis/runner/events.py

@@ -16,6 +16,9 @@
 class ExecutionEvent:
     """Generic execution event."""
 
+    # Whether this event is expected to be the last one in the event stream
+    is_terminal = False
+
     def asdict(self, **kwargs: Any) -> Dict[str, Any]:
         data = attr.asdict(self, **kwargs)
         # An internal tag for simpler type identification
@@ -146,6 +149,8 @@ class Interrupted(ExecutionEvent):
 class InternalError(ExecutionEvent):
     """An error that happened inside the runner."""
 
+    is_terminal = True
+
     message: str = attr.ib()  # pragma: no mutate
     exception_type: str = attr.ib()  # pragma: no mutate
     exception: Optional[str] = attr.ib(default=None)  # pragma: no mutate
@@ -182,6 +187,8 @@ class Finished(ExecutionEvent):
     No more events after this point.
     """
 
+    is_terminal = True
+
     passed_count: int = attr.ib()  # pragma: no mutate
     failed_count: int = attr.ib()  # pragma: no mutate
     errored_count: int = attr.ib()  # pragma: no mutate