911b973d70
currently we create queue per pipeline which is not necessary. it creates more memory usage and doesn't necessarily distribute work more effectively. this hashes data to queues based on manager but still internally, the data is destined to specific pipeline based on event_type. this will minimise queue usage while keeping internal code path the same. Change-Id: I0ccd51f13457f208fe2ccedb6e680c91e132f78f |
||
---|---|---|
.. | ||
data | ||
__init__.py | ||
base.py | ||
event.py | ||
sample.py |