fix typecheck

Author: jverre

src/index.ts

@@ -1,6 +1,6 @@
 // Main entry point for the package
 export { applyPatches } from "./patch-n8n.js";
-export { setupObservability, shutdownObservability, flushObservability } from "./otel-setup.js";
+export { setupObservability, shutdownObservability } from "./otel-setup.js";
 
 // For programmatic setup
 export async function setupN8nObservability(options?: {

src/otel-setup.ts

@@ -294,15 +294,6 @@ export function setupObservability(options: ObservabilityOptions = {}): void {
   }
 }
 
-/**
- * Force flush all pending telemetry (without shutting down)
- */
-export async function flushObservability(): Promise<void> {
-  if (sdkInstance) {
-    await sdkInstance.forceFlush();
-  }
-}
-
 /**
  * Shutdown the OpenTelemetry SDK
  */

src/patch-n8n.ts

@@ -13,15 +13,6 @@ import {
 import { flatten } from "flat";
 import type { IExecuteData, INodeExecutionData } from "n8n-workflow";
 
-// Import the flush function
-let flushObservability: (() => Promise<void>) | null = null;
-try {
-  const otelSetup = require("./otel-setup.js");
-  flushObservability = otelSetup.flushObservability;
-} catch {
-  // Flush not available
-}
-
 type AnyFunction = (...args: unknown[]) => unknown;
 
 type WorkflowMeta = { id?: string; name?: string };
@@ -444,15 +435,6 @@ function patchWorkflowExecute(core: unknown): boolean {
             throw err;
           } finally {
             span.end();
-            
-            // Explicitly flush spans after workflow completes (for CLI mode)
-            if (flushObservability) {
-              try {
-                await flushObservability();
-              } catch {
-                // Ignore flush errors
-              }
-            }
           }
         }
       );