Chinmay Chandak

Okay, let me take a look

> We just need to figure out the difference between this implementation and the existing one and add an `if dask:` functionality. @jsmaupin The `if dask:` implementation worked in `from_kafka_batched`...

@martindurant Could you also please take a look at this?

I guess we can close this now, since we have `#pragma no cover` and also `flaky` markers for tests? Or are there places where we can improve?

Oh, I understand now. I misunderstood the purpose of this PR then. Apologies!

We no longer have any `cuDF` tests in streamz, though, so the coverage is back on track. And branches of execution which are not tested because of cuDF/cuStreamz-specific functionality have...

> since they need to be created and applied (unless we expect the issue posters to self-apply), and there are not enough people watching this repo to need to filter...

There are also a lot of inactive or rather old (outdated with the new functionality added) issues, which would be good to close. Just another thing that could be a...

No, it does not happen with Pandas. So, we’ve not tried out all the functions so far, but all the simple aggregations (max, sum, count, etc.), as well as single-index...

Yes, we should!