search

ORNL / flowcept

Runtime data integration system that empowers any data processing system to capture and query workflow provenance using data observability.
MIT License
1 stars 3 forks source link

Main < Dev: Context management #102

Closed renan-souza closed 6 months ago

renan-souza commented 6 months ago

I had to do a major refactor of how interceptors close, especially because they were resetting the MQ_TIME_BASED_FLUSHER_THREAD when the ConsumerAPI was instantiated, causing the doc inserter to wait forever to be safe to stop.

I changed the mechanism to use sets of interceptor_ids instead of counters, which is more robust.