Andrey Novitskiy
Andrey Novitskiy
I noticed that current implementation of `is_open` in `WSAsyncConn` looks a bit buggy: ``` @property def is_open(self) -> bool: return self.conn and not self.conn.closed ``` `self.conn` is an instance of...
From https://github.com/dask/dask-cloudprovider/issues/47 ECSCluster parses logs to get Worker/Scheduler address, this may lead to bugs. We can use ECS API to get private/public IPs https://github.com/dask/dask-cloudprovider/issues/47#issuecomment-931056815 https://github.com/dask/dask-cloudprovider/issues/47#issuecomment-932166175 https://github.com/dask/dask-cloudprovider/issues/47#issuecomment-932298592
From briefly looking through code, L3_BOOK callback is not supported. Any reason why? Should it be added?
Hi, thanks for the great project! What I'm trying to achieve is to create a custom builder interface/wrapper around streamz to have predefined building blocks of preconfigured streams which can...
Is there such a stream? I want to hold all of the events appeared within a giving time range starting from now (and do some aggregation downstream), e.g. all of...
I want to use streamz for offline processing on historical data, the data is timestamped. Looking through source code, time related streams (e.g. `timed_window`, `delay`, `rate_limit`, etc.) use `time()` function...
### What happened? Up: `gefyra up --minikube minikube-1 ` Running `gefyra run -i apiserver_dev:latest -N myapiserver -n default -v $(pwd):/code` on `minikube` with `colima` on M2 Mac gives: `[ERROR] Gefyra...
I have a generated client code for FastAPI multi-file upload endpoint which I'm using like this: ``` file_names = ['fd1.py', 'fd2.py'] files = [] for f in file_names: with open(f,...
Hi, I've recently come across [AdaptDL](https://adaptdl.readthedocs.io/en/latest/) - a hyperparameter/GPU resources aware scheduler for Deep Learning training which dynamically adjusts batch size and learning rate as well as GPU budget per...
To unlock fault tolerance we need a proper data model to store operators' state and a backend to persist the state. This includes 1. A common interface/serializable data model to...