Jordan Frazier
Jordan Frazier
Still issues around `sending` the future across threads, I think. Also had to use the `tokio::sync::Mutex` in order to hold the lock across the `await`, but I'm not sure that...
There exists a deadlock when running the following: ``` import kaskada as kd import asyncio kd.init_session() data1 = "\n".join( [ "time,key,m,n", "1996-12-19T16:39:57,A,5,10", "1996-12-19T16:39:58,B,24,3", "1996-12-19T16:39:59,A,17,6", "1996-12-19T16:40:00,A,,9", "1996-12-19T16:40:01,A,12,", "1996-12-19T16:40:02,A,,", ] ) data2...
Partitioned scheduling uses a `ScheduleCount` to keep track of whether tasks need to be scheduled / re-scheduled. However, there may exist race conditions where the pipeline itself needs to re-schedule...
### Summary The current `Batch` passes around the watermark with optional `data`. ``` #[derive(Clone, PartialEq, Debug)] pub struct Batch { /// The data associated with the batch. pub(crate) data: Option,...
### Summary Merge uses a special `spread` kernel that keeps track of past values _for each column_ that are being merged. The behavior may be `latched` or `unlatched`, depending on...
see https://github.com/kaskada-ai/kaskada/pull/803#discussion_r1355312476
## Summary Windows build fails to parse an invalid URL due to presence of tilde in prepared file path. ## Initial Bug: Below is initial bug finding: Windows build is...
## Summary This behavior was first noticed in the the test described in https://github.com/kaskada-ai/kaskada/pull/682, where it was expected that using `coalesce` would pick the second `record`, but it always gets...
## Summary Discussing the continuity of shift-by: whether it should be continuous or discrete, or whether the argument to the shift-by can influence the continuity. ## Current Behavior Shift-by is...