kellen

Do not merge until 0.12.0 is finalized. For RC1 release only

Postgres: Cannot perform operation: another operation is in progress

6

Using broadcaster w/ fastapi and seeing an exception when using broadcaster via websockets. Relevant parts: ``` await self._conn.execute("SELECT pg_notify($1, $2);", channel, message) # ... 'cannot perform operation: another operation is...

[The docs](https://spotify.github.io/scio/api/com/spotify/scio/hash/MutableScalableBloomFilter.html) incorrectly imply that MSBF maintains `fppProb` for you (rather than it being the initial fpProb) and that `tighteningRatio` will keep `fppProb` in line, rather than that you must...

PubSubIO.WriteParam isn't inferred correctly in IntelliJ for subtypes

1

e.g. when using: ```scala val scoll: SCollection[MyMessage] = ??? scoll.write(PubsubIO.proto[MyMessage](topic))(PubsubIO.WriteParam()) ``` IntelliJ will infer `Nothing` as the type for the second argument to `write`. Not sure how/if this is possible...

and add example

Add option/env var indicating job should be cancelled on interrupt

1

Capture in `waitUntilFinish` and add a shutdown hook

When users experience "job graph too large" issues, the problem is typically implicitly-derived coders or parquet config. We could potentially capture this exception and analyze the graph to automatically suggest...

e.g. unwindowed -> typical result from DefaultFilenamePolicy, windowed -> daily GCS dirs

With no current BOM support in sbt, the recommended way to ship a set of dependencies (see sbt/sbt#4531) is via a plugin. This wouldn't have quite the same semantics as...

Added to beam per internal user requests in apache/beam#26044, we should have a nicer variant in scio