roekatz

Pubsub: Use new broadcaster disconnection bugfix (conditioned with a feature flag)

1

Make pubsub server compatible with the new fastapi_websocket_pubsub api. This is important in order for fastapi_websocket_pubsub to be able to wait on the broadcaster's reading task, and bailing out on...

``` INFO:root:Downloading http://taxbills.nyc/joined.csv to /nycdb/src/data/taxbills_joined.csv DEBUG:urllib3.connectionpool:Starting new HTTP connection (1): taxbills.nyc:80 Traceback (most recent call last): File "/usr/local/lib/python3.10/site-packages/urllib3/connection.py", line 174, in _new_conn conn = connection.create_connection( File "/usr/local/lib/python3.10/site-packages/urllib3/util/connection.py", line 96, in...

Rename `DATA_STORE_CONN_RETRY` to `DATA_UPDATER_CONN_RETRY`

1

This configuration variable sets the retry params for the data updater that fetches data from server. The new name is more inline with the name of the similar variable for...

[Snyk] Security upgrade gunicorn from 20.1.0 to 22.0.0

1

This PR was automatically created by Snyk using the credentials of a real user.Snyk has created this PR to fix one or more vulnerable packages in the `pip` dependencies of...

[Snyk] Fix for 3 vulnerabilities

1

This PR was automatically created by Snyk using the credentials of a real user.Snyk has created this PR to fix one or more vulnerable packages in the `pip` dependencies of...

Moving the broadcaster channel `disconnect` call to `__aexit__` would not necessarily behave the same as calling `disconnect` upon exiting the reader task.