feat(agent): integrate TAP mngr in SenderAllocationTask

Signed-off-by: Joseph Livesey <[email protected]>

Author: suchapalaver

Cargo.lock

@@ -87,6 +87,7 @@ tap_aggregator = { version = "0.5.6", default-features = false }
 tap_core = { version = "4.1.4", default-features = false }
 tap_graph = { version = "0.3.4", features = ["v2"] }
 tempfile = "3.8.0"
+testcontainers-modules = { version = "0.12.1", features = ["postgres"] }
 test-log = { version = "0.2.12", default-features = false }
 testcontainers-modules = { version = "0.12.1", features = ["postgres"] }
 test-with = "0.14.6"

Cargo.toml

@@ -67,3 +67,4 @@ test-log = { workspace = true, features = ["trace"] }
 rstest.workspace = true
 stdext.workspace = true
 insta.workspace = true
+testcontainers-modules = { workspace = true, features = ["postgres"] }

crates/tap-agent/Cargo.toml

@@ -274,6 +274,7 @@ impl SenderAccountTask {
                         Some(task_name.clone()),
                         allocation_id,
                         self_handle,
+                        state.pgpool.clone(),
                     )
                     .await?
                 }
@@ -283,6 +284,7 @@ impl SenderAccountTask {
                         Some(task_name.clone()),
                         allocation_id,
                         self_handle,
+                        state.pgpool.clone(),
                     )
                     .await?
                 }