Sidhant Kohli
Sidhant Kohli
# Summary In the current system we do have multiple things that the user can see, but we need to add more metrics which can help for better observability and...
### Observed behavior Running 2 streams on a jetstream cluster with 3 nodes The server config are as follows ``` Process Details: Version: 2.10.18 Git Commit: 57d23ac Go Version: go1.22.5...
Merge once https://github.com/numaproj/numaflow-python/pull/191 is merged
If we do not use the current replicas here, this could often be a false alarm right? As in sudden spikes the desired can go beyond maxReplicas many times _Originally...
PR to make source streaming in nature. We have removed the sync source from the implementation Refer: https://grpc.io/docs/guides/performance/#python _Streaming RPCs create extra threads for receiving and possibly sending the messages,...
While adding a new PR, we should have a workflow which builds the SDK image without **pushing** This will help to ensure that all builds are consistent
In the current setup, this is difficult to test via UT directly. I tried to add the test there but the assert.Panics (which internally uses recover) was not able to...
The current implementation does not have a range based exponential bucket function. This can be useful in scenarios where the end user doesn't want to perform manual calculations for extracting...
# Summary In certain scenarios like exceeding resource quota the pipeline vertex/monovertex goes into a failed state failing to reconcile. If this persists, there can be conditions where we would...