@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.