@dominicm Correct. For local-rt, you'd build this around the outsides of local-rt, perhaps with core.async timeout channels controlling the api/tick
actions.
I was trying to be lazy, and let onyx do that hard work for me 😁
@dominicm You can do it fully distributed Onyx, with batch-timeout & batch-size. 🙂
@michaeldrogalis that might be a little heavy for what I need. I'm doing a relatively simple ETL job which streams in.
@dominicm Yeah, makes sense. Something simple around local-rt should do the trick since it's stateless.