runtime: fix flakey connector deadlock

Image connectors can deadlock at high volumes of requests and response due to channel stuffing. Specifically it's not okay to await a send into the container while not concurrently polling for container responses. Re-work the state machine to forward non-error responses using a separate spawned task, which is joined over only upon terminal error or completion.
estuary · Sep 15, 2023 · 2d3a0ff · 2d3a0ff
1 parent f6ed956
commit 2d3a0ff
Show file tree

Hide file tree

Showing 2 changed files with 143 additions and 191 deletions.
diff --git a/crates/derive-typescript/src/main.rs b/crates/derive-typescript/src/main.rs
@@ -1,4 +1,4 @@
-use tracing_subscriber::{filter::LevelFilter, EnvFilter};
+use tracing_subscriber::EnvFilter;
 
 fn main() -> anyhow::Result<()> {
     tracing_subscriber::fmt::fmt()