Versions follow Semantic Versioning (<major>.<minor>.<patch>).
Backward incompatible (breaking) changes will only be introduced in major versions with advance notice in the Deprecations section of releases.
- #54: Add a Jupyter notebook processor that allows running parameterized notebooks using papermill
- #46: Allow multiple collectors to feed data into the processors chain
- #47: Forwarders always run concurrently now
- #48: Create a test event collector(generator)
- #49: Turn the noop processor into the test event processor(generator)
- #50: Allow defining if a pipeline should restart or not when it ends or when it fails during processing.
- #52: Chain processors asynchronously
- #47: Add a timed test case to verify concurrency
- #41: AsyncIO cooperative file reads/writes. Support glob matching on paths.
- #42: Explicitly create a new loop and assign it to the current thread and avoid a DeprecationWarning
- #43: Fix the seek to end of file call
- #44: Import TypedDict from typing_extensions on Python < 3.9.2
- #40: Allow the file collector to read from multiple files at a time
- #31: Refactored the logs collector into a generic file collector
- #33: If a processor decides not to return the passed event, no attempts to run the next processor on it or just forward it should be made
- #34: Log the traceback on the first time a pipeline run raises an exception
- #37: Processors can now return 1 or more events, they'll all get forwarded
- #32: If one of the processors raises an exception, stop processing the event
- #30: The CollectedEvent.data type is now Mapping instead of Dict. This allows to use TypedDict's for that attribute.
First public release of the project.