diff --git a/.github/workflows/test.yaml b/.github/workflows/test.yaml
index 5b669ebc0..a2f63deb4 100644
--- a/.github/workflows/test.yaml
+++ b/.github/workflows/test.yaml
@@ -40,6 +40,10 @@ jobs:
           cargo build --manifest-path=roles/Cargo.toml
           cargo build --manifest-path=utils/Cargo.toml
 
+      - name: Roles Integration Tests
+        run: |
+          cargo test --manifest-path=roles/Cargo.toml --verbose --test '*' -- --nocapture
+
       - name: Run sv1-client-and-server example
         run: |
           cargo run --manifest-path=examples/sv1-client-and-server/Cargo.toml --bin client_and_server -- 60
diff --git a/roles/tests-integration/tests/pool_integration.rs b/roles/tests-integration/tests/pool_integration.rs
new file mode 100644
index 000000000..4e9fc123a
--- /dev/null
+++ b/roles/tests-integration/tests/pool_integration.rs
@@ -0,0 +1,31 @@
+use std::str::FromStr;
+
+mod common;
+
+#[tokio::test]
+async fn success_pool_template_provider_connection() {
+    assert!(common::start_template_provider_and_pool().await.is_ok());
+}
+
+#[tokio::test]
+async fn pool_bad_coinbase_output() {
+    let (template_provider, template_provider_port) = common::start_template_provider().await;
+    let invalid_coinbase_output = vec![pool_sv2::mining_pool::CoinbaseOutput::new(
+	"P2PK".to_string(),
+	"04466d7fcae563e5cb09a0d1870bb580344804617879a14949cf22285f1bae3f276728176c3c6431f8eeda4538dc37c865e2784f3a9e77d044f33e407797e1278".to_string(),
+  )];
+    let template_provider_address =
+        std::net::SocketAddr::from_str(&format!("127.0.0.1:{}", template_provider_port)).unwrap();
+    let test_pool = common::TestPoolSv2::new(
+        None,
+        Some(invalid_coinbase_output),
+        Some(template_provider_address),
+    );
+    let pool = test_pool.pool.clone();
+    let state = pool.state().await.safe_lock(|s| s.clone()).unwrap();
+    assert_eq!(state, pool_sv2::PoolState::Initial);
+    assert!(pool.start().await.is_err());
+    let state = pool.state().await.safe_lock(|s| s.clone()).unwrap();
+    assert_eq!(state, pool_sv2::PoolState::Initial);
+    template_provider.stop();
+}