diff --git a/packages/extension-query/src/FailureHandler.ts b/packages/extension-query/src/FailureHandler.ts
new file mode 100644
index 0000000..96d784b
--- /dev/null
+++ b/packages/extension-query/src/FailureHandler.ts
@@ -0,0 +1,11 @@
+import { Effect, type Queue, type Stream } from "effect"
+
+
+export interface FailureHandler<E> {
+    readonly failures: Stream.Stream<E>
+    readonly queue: Queue.Queue<E>
+}
+
+export const Tag = <const Id extends string>(id: Id) => <
+    Self, E = never,
+>() => Effect.Tag(id)<Self, FailureHandler<E>>()
diff --git a/packages/extension-query/src/QueryExtension.ts b/packages/extension-query/src/QueryExtension.ts
index 1a55d78..888fda6 100644
--- a/packages/extension-query/src/QueryExtension.ts
+++ b/packages/extension-query/src/QueryExtension.ts
@@ -6,11 +6,11 @@ import * as QueryRunner from "./QueryRunner.js"
 import type * as QueryService from "./QueryService.js"
 
 
-export interface QueryExtension<GlobalE> {
+export interface QueryExtension<HandlerE> {
     useQuery<K extends readonly unknown[], A, E, R>(
         this: ReffuseHelpers.ReffuseHelpers<R>,
         props: UseQueryProps<K, A, E, R>,
-    ): UseQueryResult<K, A, Exclude<E, GlobalE>>
+    ): UseQueryResult<K, A, Exclude<E, HandlerE>>
 }
 
 export interface UseQueryProps<K extends readonly unknown[], A, E, R> {